|
@@ -317,6 +317,7 @@ class MangaPresenter(
|
|
|
observeDownloadsStatusSubscription?.let { remove(it) }
|
|
|
observeDownloadsStatusSubscription = downloadManager.queue.getStatusObservable()
|
|
|
.observeOn(AndroidSchedulers.mainThread())
|
|
|
+ .onBackpressureLatest()
|
|
|
.filter { download -> download.manga.id == manga.id }
|
|
|
.doOnNext { onDownloadStatusChange(it) }
|
|
|
.subscribeLatestCache(MangaController::onChapterDownloadUpdate) { _, error ->
|
|
@@ -326,6 +327,7 @@ class MangaPresenter(
|
|
|
observeDownloadsPageSubscription?.let { remove(it) }
|
|
|
observeDownloadsPageSubscription = downloadManager.queue.getProgressObservable()
|
|
|
.observeOn(AndroidSchedulers.mainThread())
|
|
|
+ .onBackpressureLatest()
|
|
|
.filter { download -> download.manga.id == manga.id }
|
|
|
.subscribeLatestCache(MangaController::onChapterDownloadUpdate) { _, error ->
|
|
|
Timber.e(error)
|