Mirrors
/
prologic-msgbus
mirror of https://git.mills.io/prologic/msgbus.git
6
0
Fork 0
Code Issues Projects Releases Wiki Activity

Even curiouser

This commit is contained in:
James Mills 2022-04-04 10:42:20 +10:00
parent dbf3aedf5e
commit 08d9bf34b0
No known key found for this signature in database
GPG Key ID: AC4C014F1440EBD6
1 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
msgbus_test.go
View File

@ -200,8 +200,8 @@ func TestMessageBusSubscribeWithIndex(t *testing.T) {
mb.Unsubscribe("id1", "foo")
mb.Put(mb.NewMessage(topic, []byte("bar"))) // ID == 2
mb.Put(mb.NewMessage(topic, []byte("baz"))) // ID == 3
require.NoError(mb.Put(mb.NewMessage(topic, []byte("bar")))) // ID == 2
require.NoError(mb.Put(mb.NewMessage(topic, []byte("baz")))) // ID == 3
msgs = mb.Subscribe("id1", "foo", WithIndex(1))