(GetUpdates): matching a bit code with Mihon

Author: cuong-tran

app/src/main/java/eu/kanade/tachiyomi/data/download/DownloadManager.kt

@@ -7,7 +7,6 @@ import eu.kanade.tachiyomi.source.Source
 import eu.kanade.tachiyomi.source.model.Page
 import eu.kanade.tachiyomi.util.storage.DiskUtil
 import exh.log.xLogE
-import kotlinx.coroutines.DelicateCoroutinesApi
 import kotlinx.coroutines.flow.Flow
 import kotlinx.coroutines.flow.asFlow
 import kotlinx.coroutines.flow.drop
@@ -37,7 +36,6 @@ import uy.kohesive.injekt.api.get
  * and retrieved through dependency injection. You can use this class to queue new chapters or query
  * downloaded chapters.
  */
-@OptIn(DelicateCoroutinesApi::class)
 class DownloadManager(
     private val context: Context,
     private val provider: DownloadProvider = Injekt.get(),

domain/src/main/java/tachiyomi/domain/updates/interactor/GetUpdates.kt

@@ -3,8 +3,6 @@ package tachiyomi.domain.updates.interactor
 import kotlinx.coroutines.delay
 import kotlinx.coroutines.flow.Flow
 import kotlinx.coroutines.flow.catch
-import kotlinx.coroutines.flow.first
-import kotlinx.coroutines.flow.flow
 import kotlinx.coroutines.flow.retry
 import logcat.LogPriority
 import tachiyomi.core.common.util.system.logcat
@@ -18,13 +16,7 @@ class GetUpdates(
 ) {
 
     suspend fun await(read: Boolean, after: Long): List<UpdatesWithRelations> {
-        // SY -->
-        return flow {
-            emit(repository.awaitWithRead(read, after, limit = 500))
-        }
-            .catchNPE()
-            .first()
-        // SY <--
+        return repository.awaitWithRead(read, after, limit = 500)
     }
 
     fun subscribe(instant: Instant): Flow<List<UpdatesWithRelations>> {