TySS-Dev/capod
1
0
Fork 0
mirror of https://github.com/d4rken-org/capod.git synced 2026-09-15 10:46:12 -04:00
Code Issues Packages Projects Releases Wiki Activity

Fix periodic checks aborting with no data.

Browse Source
This commit is contained in:
darken
2022-09-14 18:00:18 +02:00
committed by Matthias Urhahn
parent ca2e4fec79
commit fc06c285d5
1 changed files with 6 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files
app-wear/src/main/java/eu/darken/capod/wear/core/MonitorWorker.kt
+6 -5
View File
@@ -14,15 +14,16 @@ import eu.darken.capod.common.debug.logging.Logging.Priority.VERBOSE
import eu.darken.capod.common.debug.logging.Logging.Priority.WARN
import eu.darken.capod.common.debug.logging.log
import eu.darken.capod.common.debug.logging.logTag
import eu.darken.capod.common.flow.setupCommonEventHandlers
import eu.darken.capod.main.core.GeneralSettings
import eu.darken.capod.main.core.PermissionTool
import eu.darken.capod.monitor.core.MonitorComponent
import eu.darken.capod.monitor.core.MonitorCoroutineScope
import eu.darken.capod.monitor.core.PodMonitor
import kotlinx.coroutines.*
import kotlinx.coroutines.flow.filterNotNull
import kotlinx.coroutines.flow.first
import kotlinx.coroutines.flow.launchIn
import kotlinx.coroutines.flow.onEach
import kotlinx.coroutines.flow.take
@@ -84,13 +85,13 @@ class MonitorWorker @AssistedInject constructor(
}
val monitorJob = podMonitor.mainDevice
.take(2)
.onEach { log(TAG) { "Observed: $it" } }
.filterNotNull()
.take(5)
.setupCommonEventHandlers(TAG) { "monitorJob" }
.launchIn(workerScope)
log(TAG, VERBOSE) { "Monitor job is active" }
try {
withTimeout(15 * 1000) {
withTimeout(60 * 1000) {
monitorJob.join()
}
log(TAG) { "Monitor job quit after a few takes." }