When using client streaming, if the stream is ended because of .take, .runHead or even .interruptWhen, the exit value in anyExitHandler is Success, not a failure or an interruption. In that case the underlying connection is not cancelled and could stay there forever.
As a fix, I moved the check of isSuccess to the method used for non-streaming cases, and in streaming cases we will always call cancel.
When using client streaming, if the stream is ended because of
.take,.runHeador even.interruptWhen, theexitvalue inanyExitHandlerisSuccess, not a failure or an interruption. In that case the underlying connection is not cancelled and could stay there forever.As a fix, I moved the check of
isSuccessto the method used for non-streaming cases, and in streaming cases we will always callcancel.