catch offer exceptions. See Kotlin/kotlinx.coroutines#974 (#2007)

(cherry picked from commit 9e2a24f)
apollographql · Mar 23, 2020 · bbf47ed · bbf47ed
1 parent 38b1186
commit bbf47ed
Showing 1 changed file with 4 additions and 3 deletions.
diff --git a/...tines-support/src/main/kotlin/com/apollographql/apollo/coroutines/CoroutinesExtensions.kt b/...tines-support/src/main/kotlin/com/apollographql/apollo/coroutines/CoroutinesExtensions.kt
@@ -13,9 +13,8 @@ import kotlinx.coroutines.flow.*
 
 private class ChannelCallback<T>(val channel: Channel<Response<T>>) : ApolloCall.Callback<T>() {
 
-  @ExperimentalCoroutinesApi
   override fun onResponse(response: Response<T>) {
-    if (!channel.isClosedForSend) {
+    runCatching {
       channel.offer(response)
     }
   }
@@ -196,7 +195,9 @@ fun <T> ApolloSubscriptionCall<T>.toChannel(capacity: Int = Channel.UNLIMITED):
     }
 
     override fun onResponse(response: Response<T>) {
-      channel.offer(response)
+      runCatching {
+        channel.offer(response)
+      }
     }
 
     override fun onFailure(e: ApolloException) {