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 /pool/static_pool_test.go | |
| parent | 15e6f474ef1340f4e93f213bab1cb9548e51a1e8 (diff) | |
Make sure events bus properly closed
Signed-off-by: Valery Piashchynski <[email protected]>
Diffstat (limited to 'pool/static_pool_test.go')
| -rwxr-xr-x | pool/static_pool_test.go | 3 |
1 files changed, 3 insertions, 0 deletions
diff --git a/pool/static_pool_test.go b/pool/static_pool_test.go index abef3779..717d301e 100755 --- a/pool/static_pool_test.go +++ b/pool/static_pool_test.go @@ -170,6 +170,7 @@ func Test_StaticPool_Broken_Replace(t *testing.T) { ctx := context.Background() eb, id := events.Bus() + defer eb.Unsubscribe(id) ch := make(chan events.Event, 10) err := eb.SubscribeP(id, "worker.EventWorkerStderr", ch) require.NoError(t, err) @@ -201,6 +202,7 @@ func Test_StaticPool_Broken_FromOutside(t *testing.T) { // Run pool events eb, id := events.Bus() + defer eb.Unsubscribe(id) ch := make(chan events.Event, 10) err := eb.SubscribeP(id, "pool.EventWorkerConstruct", ch) require.NoError(t, err) @@ -489,6 +491,7 @@ func Test_StaticPool_NoFreeWorkers(t *testing.T) { ctx := context.Background() eb, id := events.Bus() + defer eb.Unsubscribe(id) ch := make(chan events.Event, 10) err := eb.SubscribeP(id, "pool.EventNoFreeWorkers", ch) require.NoError(t, err) |