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
index 0209a0e25..30a02733a 100644
--- 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)
             }