Room navigation : do not replay RoomMembership Changes

This commit is contained in:
ganfra 2024-04-05 17:57:38 +02:00
parent cdadd19e6a
commit 01d45377f6

View file

@ -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))
}
}