diff options
Diffstat (limited to 'transport/socket/socket_factory_spawn_test.go')
| -rw-r--r-- | transport/socket/socket_factory_spawn_test.go | 4 |
1 files changed, 4 insertions, 0 deletions
diff --git a/transport/socket/socket_factory_spawn_test.go b/transport/socket/socket_factory_spawn_test.go index 45fb3bd5..2db2fd40 100644 --- a/transport/socket/socket_factory_spawn_test.go +++ b/transport/socket/socket_factory_spawn_test.go @@ -112,6 +112,7 @@ func Test_Tcp_Failboot2(t *testing.T) { cmd := exec.Command("php", "../../tests/failboot.php") 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) @@ -162,6 +163,7 @@ func Test_Tcp_Broken2(t *testing.T) { cmd := exec.Command("php", "../../tests/client.php", "broken", "tcp") 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) @@ -271,6 +273,7 @@ func Test_Unix_Failboot2(t *testing.T) { cmd := exec.Command("php", "../../tests/failboot.php") 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) @@ -327,6 +330,7 @@ func Test_Unix_Broken2(t *testing.T) { cmd := exec.Command("php", "../../tests/client.php", "broken", "unix") 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) |