From ed06469885e1b32f523491253b96695fe5e76c88 Mon Sep 17 00:00:00 2001 From: inorichi Date: Fri, 5 Feb 2016 15:42:53 +0100 Subject: [PATCH] Trying to fix a backpressure isue --- .../eu/kanade/tachiyomi/ui/download/DownloadPresenter.java | 1 + .../java/eu/kanade/tachiyomi/ui/reader/ReaderPresenter.java | 3 ++- 2 files changed, 3 insertions(+), 1 deletion(-) 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 fe69bc884d..36bb3d3080 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 013afe2f59..23cbfe6e23 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);