АК
Size: a a a
2020 July 22
АК
Ну да, способ хорош когда тебе где-то по пути в середине надо дропнуть стрим
АК
Сохранив из лямбды подписку
S
Есть ли Completable, который после выполнения задачи сам выполнил dispose? Одноразовый так сказать
i
Singular
Есть ли Completable, который после выполнения задачи сам выполнил dispose? Одноразовый так сказать
Есть и Completeable и Single и Maybe. Да и Flowable с Observable после onComplete отписываются
i
Скорее у тебя какой то странный комплитабл, если он ен отписывается
S
Тоесть они сами отписываются, после выполнения работы?
S
А зачем хранить эти Disposableы тогда?
AD
Singular
А зачем хранить эти Disposableы тогда?
чтобы до завершения отписаться
2020 July 23
w
Добрый день!
У меня есть две функции:
1 - получает объект Order по идшнику
2 - получает список сообщений к Order по объекту Order
я хочу объединить их, в конце, когда получу и заказ и сообщения, в свойство заказа записать сообщения и на выходе отдать готовый объект заказа.
Через что это можно сделать в rx?
У меня есть две функции:
1 - получает объект Order по идшнику
fun getOrderById(id: Int): Single<Order>
2 - получает список сообщений к Order по объекту Order
fun getMessages(order: Order): Single<List<Messages>>
я хочу объединить их, в конце, когда получу и заказ и сообщения, в свойство заказа записать сообщения и на выходе отдать готовый объект заказа.
Через что это можно сделать в rx?
АК
getOrderById(111)
.flatMap(order -> getMessages(order)
.map(listMessages -> order.putMessages(listMessages)
)
.flatMap(order -> getMessages(order)
.map(listMessages -> order.putMessages(listMessages)
)
И
getOrderById(id). flatmap{order-> getMessages(order). map{messages->order. Copy(message =message)}}
АК
getOrderById(111)
.flatMap(order -> getMessages(order)
.doOnNext(listMessages -> order.putMessages(listMessages)
.map(list ->order)
)
.flatMap(order -> getMessages(order)
.doOnNext(listMessages -> order.putMessages(listMessages)
.map(list ->order)
)
AD
getOrderById(111)
.flatMap(order -> getMessages(order)
.doOnNext(listMessages -> order.putMessages(listMessages)
.map(list ->order)
)
.flatMap(order -> getMessages(order)
.doOnNext(listMessages -> order.putMessages(listMessages)
.map(list ->order)
)
фу, мутабельность
АК
как спросили так и ответил)
w
map ... почему я про него забыл... 🙈 спасибо!
PE
Изучаю Rx (Java), не очень понятен момент с обработкой ошибок, я делаю что нужно в doOnError, но при повторном emitter.onNext(...) тупа ничего не происходит, я поставил таймаут, вот и после того как исключение TimeoutException бросается, обсервабля перестает реагировать на onNext