i
fun inc() = processor.publish(count.incrementAndGet())
fun dec() = processor.publish(count.decrementAndGet())
fun observe() = processor.map { it > 0 }
хм
Size: a a a
2020 August 19
i
Почему бы и нет )
S
Есть Single который испускает 3 элемента. Так вот после получения элементов я должен их отправить в другой Single, и дальше выполнить 1 Single.
Как сделать?
Как сделать?
I
> Single который испускает 3 элемента
это как?
это как?
I
Tripple?
S
> Single который испускает 3 элемента
это как?
это как?
фигню написал, короче обычный Single.just("ASDSSD")
S
После получения данных мы получаем их в onSuccess, но перед этим паралельно отправить данные в некий Observable.
flatMap юзать для этого?
flatMap юзать для этого?
S
Только надо чтобы flatMap вернул нам наш Observable, а не тот который паралельно отправили
2020 August 20
I
Singular
После получения данных мы получаем их в onSuccess, но перед этим паралельно отправить данные в некий Observable.
flatMap юзать для этого?
flatMap юзать для этого?
Если правильно понял, то должно быть что-то вроде
тогда ты триггерёшь свой Single, как только он даст результат, параллельно запустится
mySingle
.doAfterSuccess {
anotherPublisher()
.subscribeOn(Schedulers.io())
.subscribe()
}тогда ты триггерёшь свой Single, как только он даст результат, параллельно запустится
anotherPublisher(), который уже не залезет в onSuccess твоего изначального SingleI
но тут могут налететь из-за subscribe() внтури другого subscribe(), а я бы с удовольствием посмотрел на другое решение 🙂
АК
но тут могут налететь из-за subscribe() внтури другого subscribe(), а я бы с удовольствием посмотрел на другое решение 🙂
Через сабджект на который уже есть подписка? onNext в него например
I
Через сабджект на который уже есть подписка? onNext в него например
нууу... не знаю. моё решение мне нравится больше
АК
нууу... не знаю. моё решение мне нравится больше
как ты и говорил - сабскрайб внутри doOn - фи
I
я в своё время не нашёл проблем с subscribe внутри subscribe
I
я даже идеологически здесь не вижу проблемы, выключая то, что это норм работает
I
в условия ТСа вписывается на все 100, ИМХО
AD
нравится, как этот чувак задает вопрос, все бросаются ему на помощь, а он больше не появляется в чате до следующего вопроса)
AD
я в своё время не нашёл проблем с subscribe внутри subscribe
просто грязно немного выходит, суть Rx в том, чтобы все одной цепочкой организовать)
I
просто грязно немного выходит, суть Rx в том, чтобы все одной цепочкой организовать)
мне кажется, что тут как раз-таки сам бизнес подразумевает ответление от цепочки
AD
мне кажется, что тут как раз-таки сам бизнес подразумевает ответление от цепочки
так, пойду сам вопрос прочитаю)