From 902767ad6ef397b5f437d3e6122806ed805f0747 Mon Sep 17 00:00:00 2001
From: Horis <8674809+821938089@users.noreply.github.com>
Date: Sat, 6 Jul 2024 21:22:52 +0800
Subject: [PATCH] =?UTF-8?q?=E4=BC=98=E5=8C=96?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 app/src/main/java/io/legado/app/utils/FlowExtensions.kt | 6 +++---
 1 file changed, 3 insertions(+), 3 deletions(-)

diff --git a/app/src/main/java/io/legado/app/utils/FlowExtensions.kt b/app/src/main/java/io/legado/app/utils/FlowExtensions.kt
index c08805906..31b64913a 100644
--- a/app/src/main/java/io/legado/app/utils/FlowExtensions.kt
+++ b/app/src/main/java/io/legado/app/utils/FlowExtensions.kt
@@ -231,12 +231,12 @@ fun <T> Flow<T>.flowWithLifecycleAndDatabaseChangeFirst(
     minActiveState: Lifecycle.State = Lifecycle.State.STARTED,
     table: String
 ): Flow<T> = callbackFlow {
+    val channel = appDb.invalidationTrackerFlow(table, emitInitialState = false)
+        .conflate()
+        .produceIn(this)
     if (!lifecycle.currentState.isAtLeast(minActiveState)) {
         send(first())
     }
-    val channel = appDb.invalidationTrackerFlow(table)
-        .conflate()
-        .produceIn(this)
     lifecycle.repeatOnLifecycle(minActiveState) {
         channel.receive()
         this@flowWithLifecycleAndDatabaseChangeFirst.collect {