Download from up to 5 different sources concurrently (closes #2534)

(cherry picked from commit c9035b5df9a331dbed3322eb6ad95bc81d1d7f22)
2020-05-08 18:41:27 -04:00 · 2020-05-08 18:41:27 -04:00 · ce0d99b78f
commit ce0d99b78f
parent 3ffb80c6f1
1 changed files with 10 additions and 1 deletions
--- a/app/src/main/java/eu/kanade/tachiyomi/data/download/Downloader.kt
+++ b/app/src/main/java/eu/kanade/tachiyomi/data/download/Downloader.kt
@ -181,7 +181,16 @@ class Downloader(
        subscriptions.clear()

        subscriptions += downloadsRelay.concatMapIterable { it }
-            .concatMap { downloadChapter(it).subscribeOn(Schedulers.io()) }
+            // Concurrently download from 5 different sources
+            .groupBy { it.source }
+            .flatMap(
+                { bySource ->
+                    bySource.concatMap { download ->
+                        downloadChapter(download).subscribeOn(Schedulers.io())
+                    }
+                },
+                5
+            )
            .onBackpressureBuffer()
            .observeOn(AndroidSchedulers.mainThread())
            .subscribe(