transport: typo in handleGoAway

grpc · Jan 18, 2024 · bd15a4f · bd15a4f
1 parent 987df13
commit bd15a4f
Showing 1 changed file with 2 additions and 4 deletions.
diff --git a/internal/transport/http2_client.go b/internal/transport/http2_client.go
@@ -1325,10 +1325,8 @@ func (t *http2Client) handleGoAway(f *http2.GoAwayFrame) {
 	for streamID, stream := range t.activeStreams {
 		if streamID > id && streamID <= upperLimit {
 			// The stream was unprocessed by the server.
-			if streamID > id && streamID <= upperLimit {
-				atomic.StoreUint32(&stream.unprocessed, 1)
-				streamsToClose = append(streamsToClose, stream)
-			}
+			atomic.StoreUint32(&stream.unprocessed, 1)
+			streamsToClose = append(streamsToClose, stream)
 		}
 	}
 	t.mu.Unlock()