Increase buffer capacity for mutableRouterEvents flow within RibEvent…

…sIncrease buffer capacity for mutableRouterEvents flow within RibEvents
uber · Jun 22, 2024 · 19d6e1e · 19d6e1e
1 parent ff46554
commit 19d6e1e
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 3 deletions.
diff --git a/android/gradle.properties b/android/gradle.properties
@@ -13,7 +13,7 @@
 # org.gradle.parallel=true
 
 GROUP=com.uber.rib
-VERSION_NAME=0.16.3-SNAPSHOT
+VERSION_NAME=0.16.4-SNAPSHOT
 POM_DESCRIPTION=RIBs is the cross-platform architecture behind many mobile apps at Uber. This framework is designed for mobile apps with a large number of engineers and nested states.
 POM_URL=https://github.com/uber/RIBs/
 POM_SCM_URL=https://github.com/uber/RIBs/

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()