@@ -102,6 +102,7 @@ copyFromChan:
waitTimer.Stop()
go func() {
reader, writer := io.Pipe()
+ defer writer.Close()
streamingRespOpt := &pipedStreamingRespOption{writer}
for {