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 {