diff options
| author | Valery Piashchynski <[email protected]> | 2020-10-19 14:01:59 +0300 |
|---|---|---|
| committer | Valery Piashchynski <[email protected]> | 2020-10-19 14:01:59 +0300 |
| commit | 77670fb7af0c892c9b3a589fd424534fad288e7a (patch) | |
| tree | 3adcaa85db664a355abe2b28f1d7e4a3fc45689f /socket_factory_test.go | |
| parent | 16fbf3104c3c34bd9355593052b686acd26a8efe (diff) | |
Update according activity worker
Diffstat (limited to 'socket_factory_test.go')
| -rw-r--r-- | socket_factory_test.go | 12 |
1 files changed, 6 insertions, 6 deletions
diff --git a/socket_factory_test.go b/socket_factory_test.go index 45443337..0c953b33 100644 --- a/socket_factory_test.go +++ b/socket_factory_test.go @@ -206,7 +206,7 @@ func Test_Tcp_Broken(t *testing.T) { t.Fatal(err) } - res, err := sw.Exec(ctx, Payload{Body: []byte("hello")}) + res, err := sw.ExecWithContext(ctx, Payload{Body: []byte("hello")}) assert.Error(t, err) assert.Nil(t, res.Body) assert.Nil(t, res.Context) @@ -245,7 +245,7 @@ func Test_Tcp_Echo(t *testing.T) { t.Fatal(err) } - res, err := sw.Exec(ctx, Payload{Body: []byte("hello")}) + res, err := sw.ExecWithContext(ctx, Payload{Body: []byte("hello")}) assert.NoError(t, err) assert.NotNil(t, res) @@ -390,7 +390,7 @@ func Test_Unix_Broken(t *testing.T) { t.Fatal(err) } - res, err := sw.Exec(ctx, Payload{Body: []byte("hello")}) + res, err := sw.ExecWithContext(ctx, Payload{Body: []byte("hello")}) assert.Error(t, err) assert.Nil(t, res.Context) @@ -433,7 +433,7 @@ func Test_Unix_Echo(t *testing.T) { t.Fatal(err) } - res, err := sw.Exec(ctx, Payload{Body: []byte("hello")}) + res, err := sw.ExecWithContext(ctx, Payload{Body: []byte("hello")}) assert.NoError(t, err) assert.NotNil(t, res) @@ -511,7 +511,7 @@ func Benchmark_Tcp_Worker_ExecEcho(b *testing.B) { } for n := 0; n < b.N; n++ { - if _, err := sw.Exec(ctx, Payload{Body: []byte("hello")}); err != nil { + if _, err := sw.ExecWithContext(ctx, Payload{Body: []byte("hello")}); err != nil { b.Fail() } } @@ -579,7 +579,7 @@ func Benchmark_Unix_Worker_ExecEcho(b *testing.B) { } for n := 0; n < b.N; n++ { - if _, err := sw.Exec(ctx, Payload{Body: []byte("hello")}); err != nil { + if _, err := sw.ExecWithContext(ctx, Payload{Body: []byte("hello")}); err != nil { b.Fail() } } |