Update ChannelManager.kt

Signed-off-by: Luki <[email protected]>
lukisk · May 21, 2024 · 6d9ca47 · 6d9ca47
1 parent 63928aa
commit 6d9ca47
Showing 1 changed file with 6 additions and 1 deletion.
diff --git a/...icast/src/commonMain/kotlin/org/mobilenativefoundation/store/multicast5/ChannelManager.kt b/...icast/src/commonMain/kotlin/org/mobilenativefoundation/store/multicast5/ChannelManager.kt
@@ -22,6 +22,7 @@ import kotlinx.coroutines.CoroutineScope
 import kotlinx.coroutines.channels.SendChannel
 import kotlinx.coroutines.flow.Flow
 import org.mobilenativefoundation.store.multicast5.ChannelManager.Message
+import kotlin.coroutines.cancellation.CancellationException
 
 internal interface ChannelManager<T> {
 
@@ -55,7 +56,11 @@ internal interface ChannelManager<T> {
 
         suspend fun dispatchValue(value: Message.Dispatch.Value<T>) {
             _awaitsDispatch = false
-            channel.send(value)
+            try {
+                channel.send(value)
+            } catch (e: CancellationException) {
+                // ignore
+            }
         }
 
         fun dispatchError(error: Throwable) {