filippodb/SchildiChat-android
1
0
Fork 0
mirror of https://github.com/SchildiChat/SchildiChat-android.git synced 2025-02-03 12:37:31 +01:00
Code Issues Packages Projects Releases Wiki Activity

unused flow

Browse Source
This commit is contained in:
valere 2023-04-07 14:09:25 +02:00
parent 1b12db9270
commit 4ecbf87cda
1 changed files with 13 additions and 14 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

27
vector/src/main/java/im/vector/app/features/crypto/keysrequest/KeyRequestHandler.kt
View File

@ -28,6 +28,7 @@ import kotlinx.coroutines.Dispatchers
import kotlinx.coroutines.SupervisorJob import kotlinx.coroutines.SupervisorJob
import kotlinx.coroutines.cancel import kotlinx.coroutines.cancel
import kotlinx.coroutines.flow.cancellable import kotlinx.coroutines.flow.cancellable
import kotlinx.coroutines.flow.launchIn
import kotlinx.coroutines.flow.onEach import kotlinx.coroutines.flow.onEach
import kotlinx.coroutines.launch import kotlinx.coroutines.launch
import kotlinx.coroutines.withContext import kotlinx.coroutines.withContext
@ -73,23 +74,21 @@ class KeyRequestHandler @Inject constructor(
// This functionality is disabled in element for now. As it could be prone to social attacks // This functionality is disabled in element for now. As it could be prone to social attacks
var enablePromptingForRequest = false var enablePromptingForRequest = false
// lateinit var listenerJob: Job // lateinit var listenerJob: Job
fun start(session: Session) { fun start(session: Session) {
this.session = session this.session = session
scope = CoroutineScope(SupervisorJob() + session.coroutineScope.coroutineContext) val scope = CoroutineScope(SupervisorJob() + session.coroutineScope.coroutineContext)
// session.cryptoService().verificationService().addListener(this) this.scope = scope
scope!!.launch { session.cryptoService().verificationService().requestEventFlow()
session.cryptoService().verificationService().requestEventFlow() .cancellable()
.cancellable() .onEach {
.onEach { when (it) {
when (it) { is VerificationEvent.RequestAdded -> verificationRequestCreated(it.request)
is VerificationEvent.RequestAdded -> verificationRequestCreated(it.request) is VerificationEvent.RequestUpdated -> verificationRequestUpdated(it.request)
is VerificationEvent.RequestUpdated -> verificationRequestUpdated(it.request) is VerificationEvent.TransactionAdded -> transactionCreated(it.transaction)
is VerificationEvent.TransactionAdded -> transactionCreated(it.transaction) is VerificationEvent.TransactionUpdated -> transactionUpdated(it.transaction)
is VerificationEvent.TransactionUpdated -> transactionUpdated(it.transaction)
}
} }
} }.launchIn(scope)
session.cryptoService().addRoomKeysRequestListener(this) session.cryptoService().addRoomKeysRequestListener(this)
} }