preserve original status cause

grpc · Feb 9, 2025 · 6b523e4 · 6b523e4
1 parent a969a91
commit 6b523e4
Showing 1 changed file with 1 addition and 3 deletions.
diff --git a/stub/src/main/java/io/grpc/kotlin/ClientCalls.kt b/stub/src/main/java/io/grpc/kotlin/ClientCalls.kt
@@ -20,15 +20,13 @@ import io.grpc.CallOptions
 import io.grpc.ClientCall
 import io.grpc.MethodDescriptor
 import io.grpc.Status
-import kotlinx.coroutines.CancellationException
 import kotlinx.coroutines.CoroutineName
 import kotlinx.coroutines.NonCancellable
 import kotlinx.coroutines.cancel
 import kotlinx.coroutines.channels.Channel
 import kotlinx.coroutines.channels.onFailure
 import kotlinx.coroutines.coroutineScope
 import kotlinx.coroutines.flow.Flow
-import kotlinx.coroutines.flow.collect
 import kotlinx.coroutines.flow.flow
 import kotlinx.coroutines.launch
 import kotlinx.coroutines.withContext
@@ -296,7 +294,7 @@ object ClientCalls {
             val cause =
               when {
                 status.isOk -> null
-                status.cause is CancellationException -> status.cause
+                status.cause != null -> status.cause
                 else -> status.asException(trailersMetadata)
               }
             responses.close(cause = cause)