diff options
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) |