null2264/yokai
1
0
Fork 0
mirror of https://github.com/null2264/yokai.git synced 2025-06-21 02:34:39 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions

refactor(reader): Replace rx with kotlin coroutine

Browse source
This commit is contained in:
Ahmad Ansori Palembani 2024-12-11 19:21:41 +07:00
parent 8e7f5d8897
commit b4e3dcfdda
Signed by: null2264
GPG key ID: BA64F8B60AF3EFB6
1 changed files with 6 additions and 13 deletions
Download patch file Download diff file Expand all files Collapse all files

19
app/src/main/java/eu/kanade/tachiyomi/ui/reader/ReaderViewModel.kt
View file

@ -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(