From 3dacab3dd36152e45c2636d8723775e9ebd7eceb Mon Sep 17 00:00:00 2001
From: "Ilya.Usov" <Ilya.Usov@jetbrains.com>
Date: Wed, 30 Aug 2023 17:32:21 +0200
Subject: [PATCH] Fix SignalFlow

---
 .../src/main/kotlin/com/jetbrains/rd/util/reactive/SignalEx.kt  | 2 +-
 1 file changed, 1 insertion(+), 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
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)
             }