Fix view event replay

element-hq · Jan 10, 2023 · 9b421e2 · 9b421e2
1 parent cceb1cd
commit 9b421e2
Showing 1 changed file with 4 additions and 1 deletion.
diff --git a/vector/src/main/java/im/vector/app/core/utils/SharedEvent.kt b/vector/src/main/java/im/vector/app/core/utils/SharedEvent.kt
@@ -19,6 +19,7 @@ package im.vector.app.core.utils
 import im.vector.app.core.platform.VectorViewEvents
 import kotlinx.coroutines.flow.Flow
 import kotlinx.coroutines.flow.MutableSharedFlow
+import kotlinx.coroutines.flow.onEach
 import kotlinx.coroutines.flow.transform
 import java.util.concurrent.CopyOnWriteArraySet
 
@@ -34,7 +35,9 @@ class EventQueue<T : VectorViewEvents>(capacity: Int) : SharedEvents<T> {
         innerQueue.tryEmit(OneTimeEvent(event))
     }
 
-    override fun stream(consumerId: String): Flow<T> = innerQueue.filterNotHandledBy(consumerId)
+    override fun stream(consumerId: String): Flow<T> = innerQueue
+            .onEach { innerQueue.resetReplayCache() }
+            .filterNotHandledBy(consumerId)
 }
 
 /**