YanLongChangAn/legado
1
0
Fork 0
Code Issues Pull Requests Actions 2 Packages Projects Releases Wiki Activity

优化

Browse Source
This commit is contained in:
Horis
2024-07-06 21:22:52 +08:00
parent 1824d24267
commit 902767ad6e
1 changed files with 3 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files
app/src/main/java/io/legado/app/utils/FlowExtensions.kt
+3 -3
View File
@@ -231,12 +231,12 @@ fun <T> Flow<T>.flowWithLifecycleAndDatabaseChangeFirst(
minActiveState: Lifecycle.State = Lifecycle.State.STARTED, minActiveState: Lifecycle.State = Lifecycle.State.STARTED,
table: String table: String
): Flow<T> = callbackFlow { ): Flow<T> = callbackFlow {
val channel = appDb.invalidationTrackerFlow(table, emitInitialState = false)
.conflate()
.produceIn(this)
if (!lifecycle.currentState.isAtLeast(minActiveState)) { if (!lifecycle.currentState.isAtLeast(minActiveState)) {
send(first()) send(first())
} }
val channel = appDb.invalidationTrackerFlow(table)
.conflate()
.produceIn(this)
lifecycle.repeatOnLifecycle(minActiveState) { lifecycle.repeatOnLifecycle(minActiveState) {
channel.receive() channel.receive()
this@flowWithLifecycleAndDatabaseChangeFirst.collect { this@flowWithLifecycleAndDatabaseChangeFirst.collect {