diff --git a/transport/pipe/pipe_test.go b/transport/pipe/pipe_test.go
index 11592c17..65078b4a 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()