From f9ef44d5865f68d0f8e5796240e722cffaddd54c Mon Sep 17 00:00:00 2001
From: arkon <eugcheung94@gmail.com>
Date: Sat, 30 May 2020 18:20:19 -0400
Subject: [PATCH] Use onBackpressureLatest for chapter/page download
observables (maybe fixes #3229)
(cherry picked from commit 759795940b78d3791c2d2f765f5762d27c79a8ef)
---
.../main/java/eu/kanade/tachiyomi/data/download/Downloader.kt | 3 ++-
1 file changed, 2 insertions(+), 1 deletion(-)
diff --git a/app/src/main/java/eu/kanade/tachiyomi/data/download/Downloader.kt b/app/src/main/java/eu/kanade/tachiyomi/data/download/Downloader.kt
index ae47453eb..ec8abac84 100755
--- a/app/src/main/java/eu/kanade/tachiyomi/data/download/Downloader.kt
+++ b/app/src/main/java/eu/kanade/tachiyomi/data/download/Downloader.kt
@@ -191,7 +191,7 @@ class Downloader(
},
5
)
- .onBackpressureBuffer()
+ .onBackpressureLatest()
.observeOn(AndroidSchedulers.mainThread())
.subscribe(
{
@@ -300,6 +300,7 @@ class Downloader(
// Start downloading images, consider we can have downloaded images already
// Concurrently do 5 pages at a time
.flatMap({ page -> getOrDownloadImage(page, download, tmpDir) }, 5)
+ .onBackpressureLatest()
// Do when page is downloaded.
.doOnNext { notifier.onProgressChange(download) }
.toList()