From 2d6610e05c807f0c9aa52e5cd0ab4da310b766be Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Rafa=C5=82=20Borcz?= Date: Sat, 23 Mar 2019 01:12:17 +0100 Subject: [PATCH] Set max concurrency in sync worker (#296) --- .../main/java/io/github/wulkanowy/services/sync/SyncWorker.kt | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/app/src/main/java/io/github/wulkanowy/services/sync/SyncWorker.kt b/app/src/main/java/io/github/wulkanowy/services/sync/SyncWorker.kt index a6e44b421..5d0162f1e 100644 --- a/app/src/main/java/io/github/wulkanowy/services/sync/SyncWorker.kt +++ b/app/src/main/java/io/github/wulkanowy/services/sync/SyncWorker.kt @@ -19,6 +19,7 @@ import io.github.wulkanowy.services.sync.channels.DebugChannel import io.github.wulkanowy.services.sync.works.Work import io.github.wulkanowy.utils.getCompatColor import io.reactivex.Completable +import io.reactivex.Flowable import io.reactivex.Single import timber.log.Timber import kotlin.random.Random @@ -41,7 +42,7 @@ class SyncWorker @AssistedInject constructor( .flatMapCompletable { student -> semesterRepository.getCurrentSemester(student) .flatMapCompletable { semester -> - Completable.mergeDelayError(works.map { it.create(student, semester) }) + Completable.mergeDelayError(Flowable.fromIterable(works.map { it.create(student, semester) }), 3) } } } else Completable.complete()