L
Size: a a a
2020 February 27
VC
Observable.just(Unit)
.switchMapSingle { single1 }
.doOnNext { resultFromSingle1-> }
.switchMapSingle { resultFromSingle1-> single2 }
.doOnNext { resultFromSingle2-> }
.subscribe()
.switchMapSingle { single1 }
.doOnNext { resultFromSingle1-> }
.switchMapSingle { resultFromSingle1-> single2 }
.doOnNext { resultFromSingle2-> }
.subscribe()
VC
или как-то так
VC
давай по другому: лучше скажи какую задачу нужно решить)
VC
типа что завершен етап 1, 2 и т.д.?
VC
Observable.just(Unit)
.switchMapSingle {
single1.doOnSuccess { }
}
.switchMapSingle {
single2.doOnSuccess { }
}
.subscribe()
.switchMapSingle {
single1.doOnSuccess { }
}
.switchMapSingle {
single2.doOnSuccess { }
}
.subscribe()
UH
Пусть Observable для каждого этапа возвращает некий общий тип StageResult с информацией о выполнении конкрентого этапа. А потом по ним сделать Observable.merge.
UH
Да, упустил, что этапы могут зависеть друг от друга :[