We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent e96f521 commit 67e50beCopy full SHA for 67e50be
internal/transport/http2_client.go
@@ -1325,10 +1325,8 @@ func (t *http2Client) handleGoAway(f *http2.GoAwayFrame) {
1325
for streamID, stream := range t.activeStreams {
1326
if streamID > id && streamID <= upperLimit {
1327
// The stream was unprocessed by the server.
1328
- if streamID > id && streamID <= upperLimit {
1329
- atomic.StoreUint32(&stream.unprocessed, 1)
1330
- streamsToClose = append(streamsToClose, stream)
1331
- }
+ atomic.StoreUint32(&stream.unprocessed, 1)
+ streamsToClose = append(streamsToClose, stream)
1332
}
1333
1334
t.mu.Unlock()
0 commit comments