diff --git a/app/src/main/java/eu/kanade/tachiyomi/ui/download/DownloadPresenter.java b/app/src/main/java/eu/kanade/tachiyomi/ui/download/DownloadPresenter.java index fe69bc884..36bb3d308 100644 --- a/app/src/main/java/eu/kanade/tachiyomi/ui/download/DownloadPresenter.java +++ b/app/src/main/java/eu/kanade/tachiyomi/ui/download/DownloadPresenter.java @@ -57,6 +57,7 @@ public class DownloadPresenter extends BasePresenter { })); add(pageProgressSubscription = downloadQueue.getProgressObservable() + .onBackpressureBuffer() .observeOn(AndroidSchedulers.mainThread()) .subscribe(view::updateDownloadedPages)); } diff --git a/app/src/main/java/eu/kanade/tachiyomi/ui/reader/ReaderPresenter.java b/app/src/main/java/eu/kanade/tachiyomi/ui/reader/ReaderPresenter.java index 013afe2f5..23cbfe6e2 100644 --- a/app/src/main/java/eu/kanade/tachiyomi/ui/reader/ReaderPresenter.java +++ b/app/src/main/java/eu/kanade/tachiyomi/ui/reader/ReaderPresenter.java @@ -79,7 +79,8 @@ public class ReaderPresenter extends BasePresenter { next -> {}, error -> Timber.e("Error fetching images")); - startable(GET_ADJACENT_CHAPTERS, this::getAdjacentChaptersObservable); + startableLatestCache(GET_ADJACENT_CHAPTERS, this::getAdjacentChaptersObservable, + (view, pair) -> view.onAdjacentChapters(pair.first, pair.second)); startable(RETRY_IMAGES, this::getRetryPageObservable);