rei-forks/element-android
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

reusing the suspend scope

Browse Source
This commit is contained in:
Adam Brown 2022-08-01 13:13:00 +01:00
parent fedbe048ba
commit 410a7b525f
1 changed files with 9 additions and 11 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
vector/src/main/java/im/vector/app/core/pushers/VectorMessagingReceiver.kt
View File

@ -198,7 +198,7 @@ class VectorMessagingReceiver : MessagingReceiver() {
} }
} }
private fun getEventFastLane(session: Session, pushData: PushData) { private suspend fun getEventFastLane(session: Session, pushData: PushData) {
pushData.roomId ?: return pushData.roomId ?: return
pushData.eventId ?: return pushData.eventId ?: return
@ -212,9 +212,8 @@ class VectorMessagingReceiver : MessagingReceiver() {
return return
} }
coroutineScope.launch {
Timber.tag(loggerTag.value).d("Fast lane: start request") Timber.tag(loggerTag.value).d("Fast lane: start request")
val event = tryOrNull { session.eventService().getEvent(pushData.roomId, pushData.eventId) } ?: return@launch val event = tryOrNull { session.eventService().getEvent(pushData.roomId, pushData.eventId) } ?: return
val resolvedEvent = notifiableEventResolver.resolveInMemoryEvent(session, event, canBeReplaced = true) val resolvedEvent = notifiableEventResolver.resolveInMemoryEvent(session, event, canBeReplaced = true)
@ -224,7 +223,6 @@ class VectorMessagingReceiver : MessagingReceiver() {
notificationDrawerManager.updateEvents { it.onNotifiableEventReceived(resolvedEvent) } notificationDrawerManager.updateEvents { it.onNotifiableEventReceived(resolvedEvent) }
} }
} }
}
// check if the event was not yet received // check if the event was not yet received
// a previous catchup might have already retrieved the notified event // a previous catchup might have already retrieved the notified event