No need to launch a coroutine to send the first value.
This commit is contained in:
parent
1309d04649
commit
d14361760b
1 changed files with 2 additions and 4 deletions
|
|
@ -116,10 +116,8 @@ class RustMatrixRoom(
|
||||||
}
|
}
|
||||||
|
|
||||||
override val roomTypingMembersFlow: Flow<List<UserId>> = mxCallbackFlow {
|
override val roomTypingMembersFlow: Flow<List<UserId>> = mxCallbackFlow {
|
||||||
launch {
|
val initial = emptyList<UserId>()
|
||||||
val initial = emptyList<UserId>()
|
channel.trySend(initial)
|
||||||
channel.trySend(initial)
|
|
||||||
}
|
|
||||||
innerRoom.subscribeToTypingNotifications(object : TypingNotificationsListener {
|
innerRoom.subscribeToTypingNotifications(object : TypingNotificationsListener {
|
||||||
override fun call(typingUserIds: List<String>) {
|
override fun call(typingUserIds: List<String>) {
|
||||||
channel.trySend(
|
channel.trySend(
|
||||||
|
|
|
||||||
Loading…
Add table
Add a link
Reference in a new issue