We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent f0a8156 commit 27001ecCopy full SHA for 27001ec
http2/transport.go
@@ -1933,7 +1933,13 @@ func (rl *clientConnReadLoop) cleanup() {
1933
}
1934
cc.closed = true
1935
for _, cs := range cc.streams {
1936
- cs.abortStreamLocked(err)
+ select {
1937
+ case <-cs.peerClosed:
1938
+ // The server closed the stream before closing the conn,
1939
+ // so no need to interrupt it.
1940
+ default:
1941
+ cs.abortStreamLocked(err)
1942
+ }
1943
1944
cc.cond.Broadcast()
1945
cc.mu.Unlock()
0 commit comments