From af36b6a677aaf154c37039697375948269520253 Mon Sep 17 00:00:00 2001
From: Jobobby04 <jobobby04@users.noreply.github.com>
Date: Wed, 16 Nov 2022 16:26:37 -0500
Subject: [PATCH] Fix updates not updating UI

---
 .../java/eu/kanade/data/updates/UpdatesRepositoryImpl.kt    | 6 ++++--
 1 file changed, 4 insertions(+), 2 deletions(-)

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) }
         }
     }
 }