fix replyChan block

This commit is contained in:
adamzhoul
2021-01-11 08:36:27 +00:00
committed by GitHub
parent bb376f1616
commit 314a9c4a62

View File

@@ -208,7 +208,8 @@ func createHTTPStreams(w http.ResponseWriter, req *http.Request, opts *StreamOpt
}
// wait for stream
replyChan := make(chan struct{}, 1)
replyChan := make(chan struct{}, 4)
defer close(replyChan)
receivedStreams := 0
expectedStreams := 1
if opts.Stdout != nil {