diff --git a/core/src/main/java/io/grpc/internal/RetriableStream.java b/core/src/main/java/io/grpc/internal/RetriableStream.java index cb8904a7fe0..f301eee1f98 100644 --- a/core/src/main/java/io/grpc/internal/RetriableStream.java +++ b/core/src/main/java/io/grpc/internal/RetriableStream.java @@ -195,10 +195,7 @@ public void run() { } } if (retryFuture != null) { - boolean cancelled = retryFuture.cancel(false); - if (cancelled) { - inFlightSubStreams.decrementAndGet(); - } + retryFuture.cancel(false); } if (hedgingFuture != null) { hedgingFuture.cancel(false);