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 2f744fa commit c4031f5Copy full SHA for c4031f5
http2/transport.go
@@ -1937,7 +1937,13 @@ func (rl *clientConnReadLoop) cleanup() {
1937
}
1938
cc.closed = true
1939
for _, cs := range cc.streams {
1940
- cs.abortStreamLocked(err)
+ select {
1941
+ case <-cs.peerClosed:
1942
+ // The server closed the stream before closing the conn,
1943
+ // so no need to interrupt it.
1944
+ default:
1945
+ cs.abortStreamLocked(err)
1946
+ }
1947
1948
cc.cond.Broadcast()
1949
cc.mu.Unlock()
0 commit comments