Room navigation : do not replay RoomMembership Changes

2024-04-05 17:57:38 +02:00
parent d4e7345a01
commit 64ef638f26
1 changed files with 3 additions and 3 deletions
--- a/libraries/matrix/api/src/main/kotlin/io/element/android/libraries/matrix/api/room/RoomMembershipObserver.kt
+++ b/libraries/matrix/api/src/main/kotlin/io/element/android/libraries/matrix/api/room/RoomMembershipObserver.kt
@@ -28,10 +28,10 @@ class RoomMembershipObserver {
        val change: MembershipChange,
    )

-    private val _updates = MutableSharedFlow<RoomMembershipUpdate>(replay = 1)
+    private val _updates = MutableSharedFlow<RoomMembershipUpdate>(extraBufferCapacity = 10)
    val updates = _updates.asSharedFlow()

-    fun notifyUserLeftRoom(roomId: RoomId) {
-        _updates.tryEmit(RoomMembershipUpdate(roomId, false, MembershipChange.LEFT))
+    suspend fun notifyUserLeftRoom(roomId: RoomId) {
+        _updates.emit(RoomMembershipUpdate(roomId, false, MembershipChange.LEFT))
    }
 }