github/wulkanowy-mirror
1
0
Fork 1
mirror of https://github.com/wulkanowy/wulkanowy.git synced 2025-02-22 10:04:44 +01:00
Code

Fix rejected execution in sync worker (#305)

Browse Source
This commit is contained in:
Rafał Borcz 2019-03-26 16:47:14 +01:00 committed by Mikołaj Pich
parent b3cd7e8ac1
commit 87268b3ef6
1 changed files with 2 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
app/src/main/java/io/github/wulkanowy/services/sync/SyncWorker.kt
View File

@ -19,7 +19,6 @@ import io.github.wulkanowy.services.sync.channels.DebugChannel
import io.github.wulkanowy.services.sync.works.Work import io.github.wulkanowy.services.sync.works.Work
import io.github.wulkanowy.utils.getCompatColor import io.github.wulkanowy.utils.getCompatColor
import io.reactivex.Completable import io.reactivex.Completable
import io.reactivex.Flowable
import io.reactivex.Single import io.reactivex.Single
import timber.log.Timber import timber.log.Timber
import kotlin.random.Random import kotlin.random.Random
@ -42,12 +41,12 @@ class SyncWorker @AssistedInject constructor(
.flatMapCompletable { student -> .flatMapCompletable { student ->
semesterRepository.getCurrentSemester(student, true) semesterRepository.getCurrentSemester(student, true)
.flatMapCompletable { semester -> .flatMapCompletable { semester ->
Completable.mergeDelayError(Flowable.fromIterable(works.map { work -> Completable.mergeDelayError(works.map { work ->
work.create(student, semester) work.create(student, semester)
.doOnSubscribe { Timber.i("${work::class.java.simpleName} is starting") } .doOnSubscribe { Timber.i("${work::class.java.simpleName} is starting") }
.doOnError { Timber.i("${work::class.java.simpleName} result: An exception occurred") } .doOnError { Timber.i("${work::class.java.simpleName} result: An exception occurred") }
.doOnComplete { Timber.i("${work::class.java.simpleName} result: Success") } .doOnComplete { Timber.i("${work::class.java.simpleName} result: Success") }
}), 3) })
} }
} }
.toSingleDefault(Result.success()) .toSingleDefault(Result.success())