Fix updates not updating UI
This commit is contained in:
parent
ca9beb20c0
commit
af36b6a677
@ -5,6 +5,7 @@ import eu.kanade.data.DatabaseHandler
|
|||||||
import eu.kanade.domain.updates.model.UpdatesWithRelations
|
import eu.kanade.domain.updates.model.UpdatesWithRelations
|
||||||
import eu.kanade.domain.updates.repository.UpdatesRepository
|
import eu.kanade.domain.updates.repository.UpdatesRepository
|
||||||
import kotlinx.coroutines.flow.Flow
|
import kotlinx.coroutines.flow.Flow
|
||||||
|
import kotlinx.coroutines.flow.map
|
||||||
|
|
||||||
class UpdatesRepositoryImpl(
|
class UpdatesRepositoryImpl(
|
||||||
val databaseHandler: DatabaseHandler,
|
val databaseHandler: DatabaseHandler,
|
||||||
@ -12,8 +13,9 @@ class UpdatesRepositoryImpl(
|
|||||||
|
|
||||||
override fun subscribeAll(after: Long): Flow<List<UpdatesWithRelations>> {
|
override fun subscribeAll(after: Long): Flow<List<UpdatesWithRelations>> {
|
||||||
return databaseHandler.subscribeToList {
|
return databaseHandler.subscribeToList {
|
||||||
// updatesViewQueries.updates(after, updateWithRelationMapper)
|
updatesViewQueries.updates(after, updateWithRelationMapper)
|
||||||
(databaseHandler as AndroidDatabaseHandler).getUpdatesQuery(after)
|
}.map {
|
||||||
|
databaseHandler.awaitList { (databaseHandler as AndroidDatabaseHandler).getUpdatesQuery(after) }
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
Loading…
x
Reference in New Issue
Block a user