V
в первом случае:
cs = c1 + c2а во втором случае:
cs.subscrube
cs = c1
c1 + c2 <- новый источник не используется
cs.subscribe
Size: a a a
2020 July 16
AM
mergeWith не мутирует источник, к которому применяется, а создает новый, таким образом
в первом случае:
в первом случае:
2020 July 17
Н
Ребят, вроде тривиальная задача, а я с RX не сильно дружу. Как можно красиво сделать.
Есть 3 метода:
fun a(): Observable<Data>,
fun b(data: Data): Completable,
fun c(data: Data)Observable<Data1>
Как правильно будет вызвать эти методы последовательно, что бы в subscribe выпал результат 3ьего метода
Есть 3 метода:
fun a(): Observable<Data>,
fun b(data: Data): Completable,
fun c(data: Data)Observable<Data1>
Как правильно будет вызвать эти методы последовательно, что бы в subscribe выпал результат 3ьего метода
AD
Ребят, вроде тривиальная задача, а я с RX не сильно дружу. Как можно красиво сделать.
Есть 3 метода:
fun a(): Observable<Data>,
fun b(data: Data): Completable,
fun c(data: Data)Observable<Data1>
Как правильно будет вызвать эти методы последовательно, что бы в subscribe выпал результат 3ьего метода
Есть 3 метода:
fun a(): Observable<Data>,
fun b(data: Data): Completable,
fun c(data: Data)Observable<Data1>
Как правильно будет вызвать эти методы последовательно, что бы в subscribe выпал результат 3ьего метода
Observable.just(1)
.concatMapCompletable { Completable.complete() }
.andThen(Observable.just(2))
.concatMapCompletable { Completable.complete() }
.andThen(Observable.just(2))
Н
Ага. А я сейчас такую цепочку сделал:
a()
.flatMapSingle { data -> b(data).toSingle { data } }
.flatMap { data -> c(data) }
Или это совсем я костыль придумал?
a()
.flatMapSingle { data -> b(data).toSingle { data } }
.flatMap { data -> c(data) }
Или это совсем я костыль придумал?
AD
Ага. А я сейчас такую цепочку сделал:
a()
.flatMapSingle { data -> b(data).toSingle { data } }
.flatMap { data -> c(data) }
Или это совсем я костыль придумал?
a()
.flatMapSingle { data -> b(data).toSingle { data } }
.flatMap { data -> c(data) }
Или это совсем я костыль придумал?
не, норм, как раз поправил в ту же сторону:
Observable.just(1)
.concatMap { value -> Completable.complete().andThen(Observable.just(value)) }
Observable.just(1)
.concatMap { value -> Completable.complete().andThen(Observable.just(value)) }
Н
Спасибо)
2020 July 21
v
Почему onNext на BehavioSubject блокирующий?
v
в смысле почему он может таким оказаться?
v
обычно сразу из него возвращается, но в одном конкретном месте он у меня блокирует весь поток, пока пайплайн, в котором он находится, не завершится О_О
AD
обычно сразу из него возвращается, но в одном конкретном месте он у меня блокирует весь поток, пока пайплайн, в котором он находится, не завершится О_О
значит, ты где-то обзервишь в том же потоке, не переключаясь на свой)
v
значит, ты где-то обзервишь в том же потоке, не переключаясь на свой)
O_O
AD
ну типа у тебя Rx будет вполне себе блокирующим, если вся цепочка в одном потоке работает
AD
плюс в данном случае нижестоящий стрим будет в том потоке, в котором ты обратился к сабджекту
v
ну вот опять моё ощущение, что я начинаю понимать рхджаву, разбивается о суровую реальность
AD
ну вот опять моё ощущение, что я начинаю понимать рхджаву, разбивается о суровую реальность
добавь всем подпискам на сабджект observeOn(computation) - проблема должна уйти
v
но мне надо обзервить в мейне
v
в общем, спасибо за наводку, ща буду смотреть. Мне понравилось начало статьи, что ты скинул, оно обнадёживает)
AD
но мне надо обзервить в мейне
ну там что-то типа observeOn(comp).something().observeOn(main)