Merge pull request #434 from JetBrains/fix-asFlow-usov

Fix SignalFlow
JetBrains · Aug 30, 2023 · eade162 · eade162
2 parents dde9f6a + 3dacab3
commit eade162
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/rd-kt/rd-core/src/main/kotlin/com/jetbrains/rd/util/reactive/SignalEx.kt b/rd-kt/rd-core/src/main/kotlin/com/jetbrains/rd/util/reactive/SignalEx.kt
@@ -10,7 +10,7 @@ class SignalFlow<T>(private val signal: ISignal<T>) : Flow<T> {
 
     override suspend fun collect(collector: FlowCollector<T>): Nothing {
         Lifetime.using { lifetime ->
-            val channel = Channel<T>()
+            val channel = Channel<T>(Channel.UNLIMITED)
             signal.advise(lifetime) {
                 channel.trySend(it)
             }