Skip to content

Commit 8375901

Browse files
committed
Avoid launching coroutine for nothing.
1 parent 56986c3 commit 8375901

2 files changed

Lines changed: 7 additions & 7 deletions

File tree

matrix-sdk-android/src/main/java/org/matrix/android/sdk/internal/session/StreamEventsManager.kt

Lines changed: 4 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -42,14 +42,12 @@ internal class StreamEventsManager @Inject constructor() {
4242
listeners.remove(listener)
4343
}
4444

45-
fun dispatchLiveEventReceived(event: Event, roomId: String, initialSync: Boolean) {
45+
fun dispatchLiveEventReceived(event: Event, roomId: String) {
4646
Timber.v("## dispatchLiveEventReceived ${event.eventId}")
4747
coroutineScope.launch {
48-
if (!initialSync) {
49-
listeners.forEach {
50-
tryOrNull {
51-
it.onLiveEvent(roomId, event)
52-
}
48+
listeners.forEach {
49+
tryOrNull {
50+
it.onLiveEvent(roomId, event)
5351
}
5452
}
5553
}

matrix-sdk-android/src/main/java/org/matrix/android/sdk/internal/session/sync/handler/room/RoomSyncHandler.kt

Lines changed: 3 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -423,7 +423,9 @@ internal class RoomSyncHandler @Inject constructor(
423423
val isInitialSync = insertType == EventInsertType.INITIAL_SYNC
424424

425425
eventIds.add(event.eventId)
426-
liveEventService.get().dispatchLiveEventReceived(event, roomId, isInitialSync)
426+
if (!isInitialSync) {
427+
liveEventService.get().dispatchLiveEventReceived(event, roomId)
428+
}
427429

428430
if (event.isEncrypted() && !isInitialSync) {
429431
try {

0 commit comments

Comments
 (0)