Trying to fix a backpressure isue

This commit is contained in:
inorichi 2016-02-05 15:42:53 +01:00
parent 79cd8c691e
commit ed06469885
2 changed files with 3 additions and 1 deletions

View file

@ -57,6 +57,7 @@ public class DownloadPresenter extends BasePresenter<DownloadFragment> {
}));
add(pageProgressSubscription = downloadQueue.getProgressObservable()
.onBackpressureBuffer()
.observeOn(AndroidSchedulers.mainThread())
.subscribe(view::updateDownloadedPages));
}

View file

@ -79,7 +79,8 @@ public class ReaderPresenter extends BasePresenter<ReaderActivity> {
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);