CODEWITHSUNDEEP
androidkotlinrx-javarx-android
Esperanz0
Esperanz0

Reputation: 1586

RxJava Call Method When Loop will finish iteration

I have problem. Solution can be easy but my head is so overheat...

I want to call method ONCE after forEach loop will finish job.

Thanks for any example solution!

 override fun saveWorkers(workers: ArrayList<Worker>): Single<Boolean> {
    LogMgr.d(TAG, "saveWorkers() : $workers")

    // remove old workers for current Event Planner and save new
    workers.forEach {
        deleteOldWorkers(it.event_planner_id!!)
                .subscribeOn(getSubscriptionSchedulerForSave())
                .subscribe({ status ->

                }, { error ->

                })
    }

    return Single.create({ emitter ->
        RXModelAdapter.from(Worker::class.java)
                .saveAll(workers)
                .subscribeOn(getSubscriptionSchedulerForSave())
                .subscribe({
                    LogMgr.d(TAG, "saveWorkers() onComplete")
                    emitter.onSuccess(true)

                }, {
                    LogMgr.e(TAG, "saveWorkers() onError ", it)
                    emitter.onError(it)
                })
    })
}

  1. Proposed sulution 

        Observable.merge(workers.map {
    deleteOldWorkers(it.event_planner_id!!)
})

enter image description here

Upvotes: 1

Views: 176

Answers (1)

Maxim Volgin
Maxim Volgin

Reputation: 4077

Observable.merge(workers.map { deleteOldWorkers(it.event_planner_id!!) }).doOnComplete() perhaps?

Upvotes: 1

Related Questions