|
@ -139,7 +139,8 @@ func TestEventBusPublish(t *testing.T) { |
|
|
require.NoError(t, err) |
|
|
require.NoError(t, err) |
|
|
defer eventBus.Stop() |
|
|
defer eventBus.Stop() |
|
|
|
|
|
|
|
|
sub, err := eventBus.Subscribe(context.Background(), "test", tmquery.Empty{}) |
|
|
|
|
|
|
|
|
// FIXME: the test fails without a buffer
|
|
|
|
|
|
sub, err := eventBus.Subscribe(context.Background(), "test", tmquery.Empty{}, 14) |
|
|
require.NoError(t, err) |
|
|
require.NoError(t, err) |
|
|
|
|
|
|
|
|
const numEventsExpected = 14 |
|
|
const numEventsExpected = 14 |
|
|