N
а если у меня несколько мержей в цепочке и я просто хочу игнорить ошибку в каждом из них, правильно ли делать для каждого .onErrorResumeNext(Observable.empty()) ?
Size: a a a
2017 March 10
VB
Сорян, значит, первый
AG
Там логика такая, что мы подписываемся с самого низа. И когда у вас subscribeOn(scheduler) это означает что подписка на верхний Observable будет выполнена именно с это шедулера, и поэтому идя наверх, мы меняем шедулеры во всех subscribeOn, и лишь самый верхний будет в итоге использован.
AG
ну типо подписка снизу вверх, эмиттинг сверху вниз.
AG
@real_mista выглядит норм
2017 March 11
I
А можно в RX2 создавать
При подписывание передавал не только колбек(с next/complete/error), но и еще мой параметр - который передастся внутрь вычисления?
рект. объект (типа single/observable) с параметром?При подписывание передавал не только колбек(с next/complete/error), но и еще мой параметр - который передастся внутрь вычисления?
М
А можно в RX2 создавать
При подписывание передавал не только колбек(с next/complete/error), но и еще мой параметр - который передастся внутрь вычисления?
рект. объект (типа single/observable) с параметром?При подписывание передавал не только колбек(с next/complete/error), но и еще мой параметр - который передастся внутрь вычисления?
а зачем такое может понадобиться?
I
а зачем такое может понадобиться?
Что бы передать "реально окружение" (типа монада reader).
Те все реактивные функции там
а только создают "программу", которая потом передается исполнителю.
Типа как IO в хаскеле.
Те все реактивные функции там
ленивые и "чистые", и ничего с "сайд эффектами" не вычисляют, а только создают "программу", которая потом передается исполнителю.
Типа как IO в хаскеле.
М
можно конечно zip(), но то емного не то будет
М
Что бы передать "реально окружение" (типа монада reader).
Те все реактивные функции там
а только создают "программу", которая потом передается исполнителю.
Типа как IO в хаскеле.
Те все реактивные функции там
ленивые и "чистые", и ничего с "сайд эффектами" не вычисляют, а только создают "программу", которая потом передается исполнителю.
Типа как IO в хаскеле.
а .doOn*() не подойдут?
М
интересно можно ли именно так, как хочешь.
I
В текущей версии никак
М
под капотом возвращается UnmodifiableList
AG
@angmarr ок. Просто стало непонятно, ведь есть же способ выбора для передачи коллекции в виде аргумента, но нет способа для return коллекции
AG
Хотя непонятно как они бы это сделали
AG
Как бы это выглядело
I
под капотом возвращается UnmodifiableList
При компиляции Kotlin видит только интерфейс java.lang.List<T>, он не залазиет внутрь Java методов и не анализирует их.
I
@angmarr ок. Просто стало непонятно, ведь есть же способ выбора для передачи коллекции в виде аргумента, но нет способа для return коллекции
Если тебе так принципиально, можешь посмотреть в сторону https://github.com/ReactiveX/RxKotlin
AG
@angmarr мне не принципиально, просто в образовательных целях) спасибо за помощь)