tom

bmarty · bmarty · commit 746a7fbf373d · 2024-10-08T13:55:46.000+02:00
diff --git a/features/messages/impl/src/main/kotlin/io/element/android/features/messages/impl/crypto/identity/IdentityChangeStatePresenter.kt b/features/messages/impl/src/main/kotlin/io/element/android/features/messages/impl/crypto/identity/IdentityChangeStatePresenter.kt
@@ -25,6 +25,7 @@ import kotlinx.collections.immutable.toPersistentList
 import kotlinx.coroutines.CoroutineScope
 import kotlinx.coroutines.flow.combine
 import kotlinx.coroutines.flow.distinctUntilChanged
+import kotlinx.coroutines.flow.launchIn
 import kotlinx.coroutines.flow.onEach
 import kotlinx.coroutines.launch
 import timber.log.Timber
@@ -69,6 +70,7 @@ class IdentityChangeStatePresenter @Inject constructor(
             .onEach { roomMemberIdentityStateChanges ->
                 value = roomMemberIdentityStateChanges.toPersistentList()
             }
+            .launchIn(this)
     }
 
     private fun CoroutineScope.pinUserIdentity(userId: UserId) = launch {

Original file line number	Diff line number	Diff line change
`@@ -25,6 +25,7 @@ import kotlinx.collections.immutable.toPersistentList`
`25`	`25`	`import kotlinx.coroutines.CoroutineScope`
`26`	`26`	`import kotlinx.coroutines.flow.combine`
`27`	`27`	`import kotlinx.coroutines.flow.distinctUntilChanged`
	`28`	`+import kotlinx.coroutines.flow.launchIn`
`28`	`29`	`import kotlinx.coroutines.flow.onEach`
`29`	`30`	`import kotlinx.coroutines.launch`
`30`	`31`	`import timber.log.Timber`
`@@ -69,6 +70,7 @@ class IdentityChangeStatePresenter @Inject constructor(`
`69`	`70`	`.onEach { roomMemberIdentityStateChanges ->`
`70`	`71`	`value = roomMemberIdentityStateChanges.toPersistentList()`
`71`	`72`	`}`
	`73`	`+ .launchIn(this)`
`72`	`74`	`}`
`73`	`75`
`74`	`76`	`private fun CoroutineScope.pinUserIdentity(userId: UserId) = launch {`