Size: a a a

ReactiveX - русскоговорящее сообщество

2020 July 01

v

vitaly in ReactiveX - русскоговорящее сообщество
да у меня есть rxKotlin. Мошт, обновить его надо.
источник

v

vitaly in ReactiveX - русскоговорящее сообщество
я ещё и своей дичи понаписал наподобие zipWith который Triple возвращает)
источник

D

Dmitriy in ReactiveX - русскоговорящее сообщество
vitaly
да у меня есть rxKotlin. Мошт, обновить его надо.
проверьте импорт, очень часто бывает просто не тот
источник

AD

Aleksey D. in ReactiveX - русскоговорящее сообщество
vitaly
я ещё и своей дичи понаписал наподобие zipWith который Triple возвращает)
ну, да, встроенный только Pair умеет
источник

v

vitaly in ReactiveX - русскоговорящее сообщество
Dmitriy
проверьте импорт, очень часто бывает просто не тот
да, в курсе этой проблемы. Но конкретно сейчас не в нём проблема. Спасибо.
источник

v

vitaly in ReactiveX - русскоговорящее сообщество
у меня ещё вот такой вопрос философский есть.

есть у меня, скажем, метод такого вида:

fun doWork(): Observable<Result> {
   return Observable.just("smth")
       .concatMap {
       //тут приходят данные
}
       .concatMap {
       //тут приходят другие данные
}
       .concatMap {
       //тут приходят третие данные
}
       .concatMap {
       //тут нужны первые данные
}
}
источник

v

vitaly in ReactiveX - русскоговорящее сообщество
вопрос в том, как хендлить вот такую ситуацию, когда мне где-то далеко в цепочке нужны данные из верхнего шага
источник

v

vitaly in ReactiveX - русскоговорящее сообщество
как я пробовал:
1.  делал сабджект,
2. тащил её через всю фигню как поле object'а
3. (самое уродливое) делал месиво с помощью zip

как это ещё делается?
источник

AD

Aleksey D. in ReactiveX - русскоговорящее сообщество
vitaly
как я пробовал:
1.  делал сабджект,
2. тащил её через всю фигню как поле object'а
3. (самое уродливое) делал месиво с помощью zip

как это ещё делается?
Observable.just(…)
 .concatMap {
   doAfterStep1(it)
 }
 .concatMap {
   doAfterStep2(it)
 }

но проще Rx выкинуть в такой ситуации, имхо
источник

v

vitaly in ReactiveX - русскоговорящее сообщество
нуууу, даже с испробованными способами оно всё равно выразительнее, чем без Rx
источник

AD

Aleksey D. in ReactiveX - русскоговорящее сообщество
vitaly
нуууу, даже с испробованными способами оно всё равно выразительнее, чем без Rx
val a = getStep1()
val b = getStep2(a)
val c = getStep3(a, b)
источник

v

vitaly in ReactiveX - русскоговорящее сообщество
это с вложенными функциями?
источник

AD

Aleksey D. in ReactiveX - русскоговорящее сообщество
vitaly
это с вложенными функциями?
это без rx
источник

v

vitaly in ReactiveX - русскоговорящее сообщество
а)
источник

v

vitaly in ReactiveX - русскоговорящее сообщество
ну, обычно всё сложнее, потому что с Rx проще контролировать синхронность / асинхронность
источник

v

vitaly in ReactiveX - русскоговорящее сообщество
у меня лично)
источник

v

vitaly in ReactiveX - русскоговорящее сообщество
может, я что-то криво проектирую как обычно)
источник
2020 July 02

S

Sergey in ReactiveX - русскоговорящее сообщество
Еще раз привет всем!
Что упускаю?
Делаю вот, чтобы после каждой "1" debounce был для всех следующих элементов, а не только для этой единицы.
источник

S

Sergey in ReactiveX - русскоговорящее сообщество
источник

S

Sergey in ReactiveX - русскоговорящее сообщество
Если пишу delay, то пауза срабатывает нормально..
источник