mirror of
https://github.com/kubernetes/client-go.git
synced 2025-06-27 23:48:30 +00:00
fix replyChan block
Kubernetes-commit: 314a9c4a6215b7e57944c86acacc5c75ab55121f
This commit is contained in:
parent
2192138125
commit
5c32e970ce
@ -208,7 +208,8 @@ func createHTTPStreams(w http.ResponseWriter, req *http.Request, opts *StreamOpt
|
|||||||
}
|
}
|
||||||
|
|
||||||
// wait for stream
|
// wait for stream
|
||||||
replyChan := make(chan struct{}, 1)
|
replyChan := make(chan struct{}, 4)
|
||||||
|
defer close(replyChan)
|
||||||
receivedStreams := 0
|
receivedStreams := 0
|
||||||
expectedStreams := 1
|
expectedStreams := 1
|
||||||
if opts.Stdout != nil {
|
if opts.Stdout != nil {
|
||||||
|
Loading…
Reference in New Issue
Block a user