Remove buffer from broadcast

Trendyol · Sep 21, 2024 · 1f4c2d7 · 1f4c2d7
1 parent 97d0da5
commit 1f4c2d7
Showing 1 changed file with 0 additions and 1 deletion.
diff --git a/transmission/src/main/java/com/trendyol/transmission/router/Broadcast.kt b/transmission/src/main/java/com/trendyol/transmission/router/Broadcast.kt
@@ -20,7 +20,6 @@ fun <T> CoroutineScope.createBroadcast(): Broadcast<T> = object : Broadcast<T> {
 
     override val output by lazy {
         _source.receiveAsFlow()
-            .buffer(Channel.BUFFERED)
             .shareIn(this@createBroadcast, SharingStarted.Lazily)
     }
 }