|
|
@ -359,7 +359,7 @@ class MangaPresenter(
|
|
|
|
observeDownloadsStatusSubscription?.let { remove(it) }
|
|
|
|
observeDownloadsStatusSubscription?.let { remove(it) }
|
|
|
|
observeDownloadsStatusSubscription = downloadManager.queue.getStatusObservable()
|
|
|
|
observeDownloadsStatusSubscription = downloadManager.queue.getStatusObservable()
|
|
|
|
.observeOn(Schedulers.io())
|
|
|
|
.observeOn(Schedulers.io())
|
|
|
|
.onBackpressureLatest()
|
|
|
|
.onBackpressureBuffer()
|
|
|
|
.filter { download -> download.manga.id == manga.id }
|
|
|
|
.filter { download -> download.manga.id == manga.id }
|
|
|
|
.observeOn(AndroidSchedulers.mainThread())
|
|
|
|
.observeOn(AndroidSchedulers.mainThread())
|
|
|
|
.subscribeLatestCache(
|
|
|
|
.subscribeLatestCache(
|
|
|
@ -375,7 +375,7 @@ class MangaPresenter(
|
|
|
|
observeDownloadsPageSubscription?.let { remove(it) }
|
|
|
|
observeDownloadsPageSubscription?.let { remove(it) }
|
|
|
|
observeDownloadsPageSubscription = downloadManager.queue.getProgressObservable()
|
|
|
|
observeDownloadsPageSubscription = downloadManager.queue.getProgressObservable()
|
|
|
|
.observeOn(Schedulers.io())
|
|
|
|
.observeOn(Schedulers.io())
|
|
|
|
.onBackpressureLatest()
|
|
|
|
.onBackpressureBuffer()
|
|
|
|
.filter { download -> download.manga.id == manga.id }
|
|
|
|
.filter { download -> download.manga.id == manga.id }
|
|
|
|
.observeOn(AndroidSchedulers.mainThread())
|
|
|
|
.observeOn(AndroidSchedulers.mainThread())
|
|
|
|
.subscribeLatestCache(MangaController::onChapterDownloadUpdate) { _, error ->
|
|
|
|
.subscribeLatestCache(MangaController::onChapterDownloadUpdate) { _, error ->
|
|
|
|