From 9096edfc92e6c353b3e3a4bf8461784a6370cc88 Mon Sep 17 00:00:00 2001 From: arkon Date: Fri, 8 May 2020 19:04:45 -0400 Subject: [PATCH] Concurrently refresh trackers (cherry picked from commit 40776bdc8d4e3c42e0874ec3fec84c515b486dee) --- .../eu/kanade/tachiyomi/data/backup/BackupRestoreService.kt | 2 +- .../java/eu/kanade/tachiyomi/ui/manga/track/TrackPresenter.kt | 2 +- 2 files changed, 2 insertions(+), 2 deletions(-) diff --git a/app/src/main/java/eu/kanade/tachiyomi/data/backup/BackupRestoreService.kt b/app/src/main/java/eu/kanade/tachiyomi/data/backup/BackupRestoreService.kt index 2f431a550..7c91033d4 100644 --- a/app/src/main/java/eu/kanade/tachiyomi/data/backup/BackupRestoreService.kt +++ b/app/src/main/java/eu/kanade/tachiyomi/data/backup/BackupRestoreService.kt @@ -421,7 +421,7 @@ class BackupRestoreService : Service() { */ private fun trackingFetchObservable(manga: Manga, tracks: List): Observable { return Observable.from(tracks) - .concatMap { track -> + .flatMap { track -> val service = trackManager.getService(track.sync_id) if (service != null && service.isLogged) { service.refresh(track) diff --git a/app/src/main/java/eu/kanade/tachiyomi/ui/manga/track/TrackPresenter.kt b/app/src/main/java/eu/kanade/tachiyomi/ui/manga/track/TrackPresenter.kt index 31794cb9e..85d28c55b 100755 --- a/app/src/main/java/eu/kanade/tachiyomi/ui/manga/track/TrackPresenter.kt +++ b/app/src/main/java/eu/kanade/tachiyomi/ui/manga/track/TrackPresenter.kt @@ -58,7 +58,7 @@ class TrackPresenter( refreshSubscription?.let { remove(it) } refreshSubscription = Observable.from(trackList) .filter { it.track != null } - .concatMap { item -> + .flatMap { item -> item.service.refresh(item.track!!) .flatMap { db.insertTrack(it).asRxObservable() } .map { item }