summaryrefslogtreecommitdiff
path: root/pipe_factory_test.go
diff options
context:
space:
mode:
authorWolfy-J <[email protected]>2020-10-25 15:55:51 +0300
committerWolfy-J <[email protected]>2020-10-25 15:55:51 +0300
commitba5c562f9038ba434e655fb82c44597fcccaff16 (patch)
treeff112b9dcffda63bc40094a57d0df61622368445 /pipe_factory_test.go
parent3bdf7d02d83d1ff4726f3fbb01a45d016f39abec (diff)
- massive update in roadrunner 2.0 abstractions
Diffstat (limited to 'pipe_factory_test.go')
-rw-r--r--pipe_factory_test.go8
1 files changed, 4 insertions, 4 deletions
diff --git a/pipe_factory_test.go b/pipe_factory_test.go
index 95eededa..ee2510f3 100644
--- a/pipe_factory_test.go
+++ b/pipe_factory_test.go
@@ -101,7 +101,7 @@ func Test_Pipe_Echo(t *testing.T) {
t.Fatal(err)
}
- res, err := sw.ExecWithContext(ctx, Payload{Body: []byte("hello")})
+ res, err := sw.Exec(Payload{Body: []byte("hello")})
assert.NoError(t, err)
assert.NotNil(t, res)
@@ -129,7 +129,7 @@ func Test_Pipe_Broken(t *testing.T) {
t.Fatal(err)
}
- res, err := sw.ExecWithContext(ctx, Payload{Body: []byte("hello")})
+ res, err := sw.Exec(Payload{Body: []byte("hello")})
assert.Error(t, err)
assert.Nil(t, res.Body)
@@ -178,7 +178,7 @@ func Benchmark_Pipe_Worker_ExecEcho(b *testing.B) {
}()
for n := 0; n < b.N; n++ {
- if _, err := sw.ExecWithContext(context.Background(), Payload{Body: []byte("hello")}); err != nil {
+ if _, err := sw.Exec(Payload{Body: []byte("hello")}); err != nil {
b.Fail()
}
}
@@ -205,7 +205,7 @@ func Benchmark_Pipe_Worker_ExecEcho3(b *testing.B) {
}
for n := 0; n < b.N; n++ {
- if _, err := sw.ExecWithContext(ctx, Payload{Body: []byte("hello")}); err != nil {
+ if _, err := sw.Exec(Payload{Body: []byte("hello")}); err != nil {
b.Fail()
}
}