From f66b127c0a4a2d03798b9c1969051f6defae3dc6 Mon Sep 17 00:00:00 2001 From: Darien Raymond Date: Fri, 18 Jan 2019 21:05:50 +0100 Subject: [PATCH] fix pipe test --- transport/pipe/pipe_test.go | 2 ++ 1 file changed, 2 insertions(+) diff --git a/transport/pipe/pipe_test.go b/transport/pipe/pipe_test.go index 11592c17a..65078b4a4 100644 --- a/transport/pipe/pipe_test.go +++ b/transport/pipe/pipe_test.go @@ -117,6 +117,8 @@ func TestPipeWriteMultiThread(t *testing.T) { return pWriter.WriteMultiBuffer(buf.MultiBuffer{b}) }) } + time.Sleep(time.Millisecond * 100) + pWriter.Close() errg.Wait() b, err := pReader.ReadMultiBuffer()