diff --git a/app/src/main/java/eu/kanade/data/updates/UpdatesRepositoryImpl.kt b/app/src/main/java/eu/kanade/data/updates/UpdatesRepositoryImpl.kt
index b6f623f4c..e06cc9e3a 100644
--- a/app/src/main/java/eu/kanade/data/updates/UpdatesRepositoryImpl.kt
+++ b/app/src/main/java/eu/kanade/data/updates/UpdatesRepositoryImpl.kt
@@ -5,6 +5,7 @@ import eu.kanade.data.DatabaseHandler
 import eu.kanade.domain.updates.model.UpdatesWithRelations
 import eu.kanade.domain.updates.repository.UpdatesRepository
 import kotlinx.coroutines.flow.Flow
+import kotlinx.coroutines.flow.map
 
 class UpdatesRepositoryImpl(
     val databaseHandler: DatabaseHandler,
@@ -12,8 +13,9 @@ class UpdatesRepositoryImpl(
 
     override fun subscribeAll(after: Long): Flow<List<UpdatesWithRelations>> {
         return databaseHandler.subscribeToList {
-            // updatesViewQueries.updates(after, updateWithRelationMapper)
-            (databaseHandler as AndroidDatabaseHandler).getUpdatesQuery(after)
+            updatesViewQueries.updates(after, updateWithRelationMapper)
+        }.map {
+            databaseHandler.awaitList { (databaseHandler as AndroidDatabaseHandler).getUpdatesQuery(after) }
         }
     }
 }