|
|
@ -49,8 +49,8 @@ fun RoomList.loadingStateFlow(): Flow<RoomListLoadingState> = |
|
|
|
fun RoomList.entriesFlow(onInitialList: suspend (List<RoomListEntry>) -> Unit): Flow<List<RoomListEntriesUpdate>> = |
|
|
|
fun RoomList.entriesFlow(onInitialList: suspend (List<RoomListEntry>) -> Unit): Flow<List<RoomListEntriesUpdate>> = |
|
|
|
mxCallbackFlow { |
|
|
|
mxCallbackFlow { |
|
|
|
val listener = object : RoomListEntriesListener { |
|
|
|
val listener = object : RoomListEntriesListener { |
|
|
|
override fun onUpdate(roomEntriesUpdates: List<RoomListEntriesUpdate>) { |
|
|
|
override fun onUpdate(roomEntriesUpdate: List<RoomListEntriesUpdate>) { |
|
|
|
trySendBlocking(roomEntriesUpdates) |
|
|
|
trySendBlocking(roomEntriesUpdate) |
|
|
|
} |
|
|
|
} |
|
|
|
} |
|
|
|
} |
|
|
|
val result = entries(listener) |
|
|
|
val result = entries(listener) |
|
|
|