From b4e3dcfddae51ac8f808609ab7d95e44f936f7d5 Mon Sep 17 00:00:00 2001
From: Ahmad Ansori Palembani <palembani@gmail.com>
Date: Wed, 11 Dec 2024 19:21:41 +0700
Subject: [PATCH] refactor(reader): Replace rx with kotlin coroutine

---
 .../tachiyomi/ui/reader/ReaderViewModel.kt    | 19 ++++++-------------
 1 file changed, 6 insertions(+), 13 deletions(-)

diff --git a/app/src/main/java/eu/kanade/tachiyomi/ui/reader/ReaderViewModel.kt b/app/src/main/java/eu/kanade/tachiyomi/ui/reader/ReaderViewModel.kt
index 21c860dc8c..88374bddb0 100644
--- a/app/src/main/java/eu/kanade/tachiyomi/ui/reader/ReaderViewModel.kt
+++ b/app/src/main/java/eu/kanade/tachiyomi/ui/reader/ReaderViewModel.kt
@@ -69,8 +69,6 @@ import kotlinx.coroutines.flow.receiveAsFlow
 import kotlinx.coroutines.flow.update
 import kotlinx.coroutines.launch
 import kotlinx.coroutines.withContext
-import rx.Completable
-import rx.schedulers.Schedulers
 import uy.kohesive.injekt.Injekt
 import uy.kohesive.injekt.api.get
 import uy.kohesive.injekt.injectLazy
@@ -1012,13 +1010,9 @@ class ReaderViewModel(
         if (!chapter.chapter.read) return
         val manga = manga ?: return
 
-        Completable
-            .fromCallable {
-                downloadManager.enqueueDeleteChapters(listOf(chapter.chapter), manga)
-            }
-            .onErrorComplete()
-            .subscribeOn(Schedulers.io())
-            .subscribe()
+        viewModelScope.launchNonCancellableIO {
+            downloadManager.enqueueDeleteChapters(listOf(chapter.chapter), manga)
+        }
     }
 
     /**
@@ -1026,10 +1020,9 @@ class ReaderViewModel(
      * are ignored.
      */
     private fun deletePendingChapters() {
-        Completable.fromCallable { downloadManager.deletePendingChapters() }
-            .onErrorComplete()
-            .subscribeOn(Schedulers.io())
-            .subscribe()
+        viewModelScope.launchNonCancellableIO {
+            downloadManager.deletePendingChapters()
+        }
     }
 
     data class State(