L
Size: a a a
2020 February 27
UH
Хмм, а не будет ли в такой реализации 3 раза single1 запущен?
DG
Хмм, а не будет ли в такой реализации 3 раза single1 запущен?
будет их надо шарить тогда
UH
val single1 = Single.fromCallable { 1 }
Это холодный обзервабл
Он должен запускаться при в начале цепочки при каждой подписке
Это холодный обзервабл
Он должен запускаться при в начале цепочки при каждой подписке
VC
можно делать switchMapSingle и потом collect
VC
Observable.just(Unit)
.switchMapSingle { single1 }
.switchMapSingle { single2 }
.collect()
.switchMapSingle { single1 }
.switchMapSingle { single2 }
.collect()
VC
но нужно проверять
UH
Вот так можно гист подпилить (не запускал, но таким образом не должны промежуточные лишний раз запускаться)
val single1 = Single.fromCallable { 1 }.share()
val single2 = single1.flatMap { Single.fromCallable { it * 2 } }.share()
val single3 = single2.flatMap { Single.fromCallable { it * 3 } }2020 March 03
DG
Зарелизили новую версию 2.1 🤙