Merge pull request #635 from RahulDMello/feature/increase_rib_event_b…

…uffer_size Increase buffer capacity for mutableRouterEvents flow within RibEvents
uber · Jul 3, 2024 · 5aafed4 · 5aafed4
2 parents ff46554 + a7b33ad
commit 5aafed4
Showing 1 changed file with 3 additions and 2 deletions.
diff --git a/android/libraries/rib-base/src/main/kotlin/com/uber/rib/core/RibEvents.kt b/android/libraries/rib-base/src/main/kotlin/com/uber/rib/core/RibEvents.kt
@@ -18,15 +18,16 @@ package com.uber.rib.core
 import androidx.annotation.VisibleForTesting
 import io.reactivex.Observable
 import kotlinx.coroutines.channels.BufferOverflow
+import kotlinx.coroutines.channels.Channel
 import kotlinx.coroutines.flow.MutableSharedFlow
 import kotlinx.coroutines.rx2.asObservable
 
 public object RibEvents {
 
   private val mutableRouterEvents =
-    MutableSharedFlow<RibRouterEvent>(0, 1, BufferOverflow.DROP_OLDEST)
+    MutableSharedFlow<RibRouterEvent>(0, Channel.UNLIMITED, BufferOverflow.DROP_OLDEST)
   private val mutableRibDurationEvents =
-    MutableSharedFlow<RibActionInfo>(0, 1, BufferOverflow.DROP_OLDEST)
+    MutableSharedFlow<RibActionInfo>(0, Channel.UNLIMITED, BufferOverflow.DROP_OLDEST)
 
   @JvmStatic
   public val routerEvents: Observable<RibRouterEvent> = mutableRouterEvents.asObservable()