diff options
| author | Valery Piashchynski <[email protected]> | 2021-10-27 22:42:07 +0300 |
|---|---|---|
| committer | Valery Piashchynski <[email protected]> | 2021-10-27 22:42:07 +0300 |
| commit | 52a6b1b2fc3eaf3cda5594825f3c5a9ae8a9452b (patch) | |
| tree | 296d48dab1d5396313c061fbfc930a97af0df9f4 /events/events_test.go | |
| parent | 15e6f474ef1340f4e93f213bab1cb9548e51a1e8 (diff) | |
Make sure events bus properly closed
Signed-off-by: Valery Piashchynski <[email protected]>
Diffstat (limited to 'events/events_test.go')
| -rw-r--r-- | events/events_test.go | 6 |
1 files changed, 3 insertions, 3 deletions
diff --git a/events/events_test.go b/events/events_test.go index 6d6e90a2..e15c55d6 100644 --- a/events/events_test.go +++ b/events/events_test.go @@ -15,7 +15,7 @@ func TestEvenHandler(t *testing.T) { err := eh.SubscribeP(id, "http.EventJobOK", ch) require.NoError(t, err) - eh.Send(NewRREvent(EventJobOK, "foo", "http")) + eh.Send(NewEvent(EventJobOK, "http", "foo")) evt := <-ch require.Equal(t, "foo", evt.Message()) @@ -37,7 +37,7 @@ func TestEvenHandler2(t *testing.T) { err = eh.SubscribeP(id, "http.EventJobOK", ch2) require.NoError(t, err) - eh.Send(NewRREvent(EventJobOK, "foo", "http")) + eh.Send(NewEvent(EventJobOK, "http", "foo")) evt := <-ch2 require.Equal(t, "foo", evt.Message()) @@ -85,7 +85,7 @@ func TestEvenHandler5(t *testing.T) { err := eh.SubscribeP(id, "http.EventJobOK", ch) require.NoError(t, err) - eh.Send(NewRREvent(EventJobOK, "foo", "http")) + eh.Send(NewEvent(EventJobOK, "http", "foo")) evt := <-ch require.Equal(t, "foo", evt.Message()) |