letro/letro-android
1
0
Fork 0
Code Issues Pull Requests Actions 6 Packages Projects Releases Wiki Activity

Reuse coroutine in DefaultAnalyticsRoomListStateWatcher instead of creating and cancelling the same one

Browse Source
This commit is contained in:
Jorge Martín
2025-11-28 08:22:36 +01:00
committed by Jorge Martin Espinosa
parent f098c5e027
commit 568c1ae90d
1 changed files with 9 additions and 10 deletions
Download Patch File Download Diff File Expand all files Collapse all files

19
services/analytics/impl/src/main/kotlin/io/element/android/services/analytics/impl/watchers/DefaultAnalyticsRoomListStateWatcher.kt
View File

@@ -20,7 +20,7 @@ import io.element.android.services.analytics.api.finishLongRunningTransaction
import io.element.android.services.analytics.api.watchers.AnalyticsRoomListStateWatcher
import io.element.android.services.appnavstate.api.AppNavigationStateService
import kotlinx.coroutines.CoroutineScope
import kotlinx.coroutines.cancel
import kotlinx.coroutines.cancelChildren
import kotlinx.coroutines.flow.distinctUntilChanged
import kotlinx.coroutines.flow.launchIn
import kotlinx.coroutines.flow.map
@@ -33,19 +33,19 @@ class DefaultAnalyticsRoomListStateWatcher(
private val appNavigationStateService: AppNavigationStateService,
private val roomListService: RoomListService,
private val analyticsService: AnalyticsService,
@SessionCoroutineScope private val sessionCoroutineScope: CoroutineScope,
private val dispatchers: CoroutineDispatchers,
@SessionCoroutineScope sessionCoroutineScope: CoroutineScope,
dispatchers: CoroutineDispatchers,
) : AnalyticsRoomListStateWatcher {
private var currentCoroutineScope: CoroutineScope? = null
private val coroutineScope: CoroutineScope = sessionCoroutineScope.childScope(dispatchers.computation, "AnalyticsRoomListStateWatcher")
private val isStarted = AtomicBoolean(false)
private val isWarmState = AtomicBoolean(false)
override fun start() {
if (currentCoroutineScope != null) {
if (isStarted.getAndSet(true)) {
Timber.w("Can't start RoomListStateWatcher, it's already running.")
return
}
val coroutineScope = sessionCoroutineScope.childScope(dispatchers.computation, "AnalyticsRoomListStateWatcher")
appNavigationStateService.appNavigationState
.map { it.isInForeground }
.distinctUntilChanged()
@@ -68,12 +68,11 @@ class DefaultAnalyticsRoomListStateWatcher(
}
}
.launchIn(coroutineScope)
currentCoroutineScope = coroutineScope
}
override fun stop() {
currentCoroutineScope?.cancel()
currentCoroutineScope = null
if (isStarted.getAndSet(false)) {
coroutineScope.coroutineContext.cancelChildren()
}
}
}