summaryrefslogtreecommitdiff
path: root/pipe_factory_test.go
diff options
context:
space:
mode:
authorAnton Titov <[email protected]>2020-03-02 11:45:50 +0300
committerGitHub <[email protected]>2020-03-02 11:45:50 +0300
commitb74aedd13ef6aa0bb78bc08bb521caa36e099e9d (patch)
treebb727c3105a082ece946142fde1696ce2e895067 /pipe_factory_test.go
parent9960aff462c985f89e1e9387e0b87bab24504d0e (diff)
parent456c9934a898fbbaf8e92e1b6bd815b6a8ffeffb (diff)
Merge pull request #260 from spiral/address_already_in_use_error
Address already in use error
Diffstat (limited to 'pipe_factory_test.go')
-rw-r--r--pipe_factory_test.go4
1 files changed, 3 insertions, 1 deletions
diff --git a/pipe_factory_test.go b/pipe_factory_test.go
index 27d1f74d..14cf1272 100644
--- a/pipe_factory_test.go
+++ b/pipe_factory_test.go
@@ -4,6 +4,7 @@ import (
"github.com/stretchr/testify/assert"
"os/exec"
"testing"
+ "time"
)
func Test_Pipe_Start(t *testing.T) {
@@ -108,8 +109,9 @@ func Test_Pipe_Broken(t *testing.T) {
assert.Contains(t, err.Error(), "undefined_function()")
}()
defer func() {
+ time.Sleep(time.Second)
err := w.Stop()
- assert.Error(t, err)
+ assert.NoError(t, err)
}()
res, err := w.Exec(&Payload{Body: []byte("hello")})