mirror of https://github.com/grpc/grpc-java.git
This reverts commit c0a9d315d3.
This commit is contained in:
parent
03decafa1f
commit
5faab7f47e
|
|
@ -195,10 +195,7 @@ abstract class RetriableStream<ReqT> implements ClientStream {
|
|||
}
|
||||
}
|
||||
if (retryFuture != null) {
|
||||
boolean cancelled = retryFuture.cancel(false);
|
||||
if (cancelled) {
|
||||
inFlightSubStreams.decrementAndGet();
|
||||
}
|
||||
retryFuture.cancel(false);
|
||||
}
|
||||
if (hedgingFuture != null) {
|
||||
hedgingFuture.cancel(false);
|
||||
|
|
|
|||
Loading…
Reference in New Issue