From 77670fb7af0c892c9b3a589fd424534fad288e7a Mon Sep 17 00:00:00 2001 From: Valery Piashchynski Date: Mon, 19 Oct 2020 14:01:59 +0300 Subject: Update according activity worker --- socket_factory_test.go | 12 ++++++------ 1 file changed, 6 insertions(+), 6 deletions(-) (limited to 'socket_factory_test.go') 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() } } -- cgit v1.2.3