File tree Expand file tree Collapse file tree 1 file changed +1
-3
lines changed
stub/src/main/java/io/grpc/kotlin Expand file tree Collapse file tree 1 file changed +1
-3
lines changed Original file line number Diff line number Diff line change @@ -20,15 +20,13 @@ import io.grpc.CallOptions
2020import io.grpc.ClientCall
2121import io.grpc.MethodDescriptor
2222import io.grpc.Status
23- import kotlinx.coroutines.CancellationException
2423import kotlinx.coroutines.CoroutineName
2524import kotlinx.coroutines.NonCancellable
2625import kotlinx.coroutines.cancel
2726import kotlinx.coroutines.channels.Channel
2827import kotlinx.coroutines.channels.onFailure
2928import kotlinx.coroutines.coroutineScope
3029import kotlinx.coroutines.flow.Flow
31- import kotlinx.coroutines.flow.collect
3230import kotlinx.coroutines.flow.flow
3331import kotlinx.coroutines.launch
3432import kotlinx.coroutines.withContext
@@ -296,7 +294,7 @@ object ClientCalls {
296294 val cause =
297295 when {
298296 status.isOk -> null
299- status.cause is CancellationException -> status.cause
297+ status.cause != null -> status.cause
300298 else -> status.asException(trailersMetadata)
301299 }
302300 responses.close(cause = cause)
You can’t perform that action at this time.
0 commit comments