diff options
Diffstat (limited to 'transport')
| -rw-r--r-- | transport/pipe/pipe_factory_spawn_test.go | 2 | ||||
| -rwxr-xr-x | transport/pipe/pipe_factory_test.go | 2 | ||||
| -rw-r--r-- | transport/socket/socket_factory_spawn_test.go | 4 | ||||
| -rwxr-xr-x | transport/socket/socket_factory_test.go | 4 |
4 files changed, 12 insertions, 0 deletions
diff --git a/transport/pipe/pipe_factory_spawn_test.go b/transport/pipe/pipe_factory_spawn_test.go index 81004027..256176de 100644 --- a/transport/pipe/pipe_factory_spawn_test.go +++ b/transport/pipe/pipe_factory_spawn_test.go @@ -108,6 +108,7 @@ func Test_Pipe_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) @@ -370,6 +371,7 @@ func Test_Broken2(t *testing.T) { cmd := exec.Command("php", "../../tests/client.php", "broken", "pipes") 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) diff --git a/transport/pipe/pipe_factory_test.go b/transport/pipe/pipe_factory_test.go index 8c6d440a..0f527cd5 100755 --- a/transport/pipe/pipe_factory_test.go +++ b/transport/pipe/pipe_factory_test.go @@ -127,6 +127,7 @@ func Test_Pipe_Failboot(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) @@ -434,6 +435,7 @@ func Test_Broken(t *testing.T) { cmd := exec.Command("php", "../../tests/client.php", "broken", "pipes") 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) 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) diff --git a/transport/socket/socket_factory_test.go b/transport/socket/socket_factory_test.go index 11b34999..7b28a847 100755 --- a/transport/socket/socket_factory_test.go +++ b/transport/socket/socket_factory_test.go @@ -126,6 +126,7 @@ func Test_Tcp_Failboot(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) @@ -203,6 +204,7 @@ func Test_Tcp_Broken(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) @@ -366,6 +368,7 @@ func Test_Unix_Failboot(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) @@ -440,6 +443,7 @@ func Test_Unix_Broken(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) |