Телеграмм чат группы reactivex страница 1157

Size: a a a

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

2020 April 14

ЭМ

Эдуард Мишустин in ReactiveX - русскоговорящее сообщество

В тестах junit в @Before подменяю шедулеры следующим кодом

RxJavaPlugins.setIoSchedulerHandler { Schedulers.trampoline() }
RxJavaPlugins.setComputationSchedulerHandler { Schedulers.trampoline() }
RxJavaPlugins.setNewThreadSchedulerHandler { Schedulers.trampoline() }

Встал вопрос о необходимости в @After использовать RxJavaPlugins.reset().
Нужно ли вызывать функцию reset и почему, объяснит кто?

источник

14:03пожаловаться #1

2020 April 15

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

Если нигде больше в тестах не используется иной подход, то не нужно

источник

12:35пожаловаться #2

ЭМ

Эдуард Мишустин in ReactiveX - русскоговорящее сообщество

Используется в более чем половине тестов, везде где проcиходит вызов rx

источник

12:36пожаловаться #3

ЭМ

Эдуард Мишустин in ReactiveX - русскоговорящее сообщество

Вызывай, не вызывай reset - тесты не ломаются

источник

12:37пожаловаться #4

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

как запустить второй observable если первый observable вернул true

источник

12:58пожаловаться #5

Aleksey D. in ReactiveX - русскоговорящее сообщество

Evgeny GooDi

как запустить второй observable если первый observable вернул true

flatmap

источник

12:58пожаловаться #6

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

да пробовал, но что то он у меня не срабатывает.

источник

12:59пожаловаться #7

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

источник

13:00пожаловаться #8

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

в 138 строке пытаюсь сделать это

источник

13:00пожаловаться #9

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

проблема в том что я получаю на выходе Obsevable<Single<Boolean>> при таком раскладе

источник

13:01пожаловаться #10

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

конечно надо получить <Single<Boolean>>

источник

13:01пожаловаться #11

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

вот и чота не пойму как.

источник

13:01пожаловаться #12

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

Evgeny GooDi

FlatMapSingle

источник

13:09пожаловаться #13

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

Parabol Parabola

FlatMapSingle

он вернет Observable

источник

13:13пожаловаться #14

Aleksey D. in ReactiveX - русскоговорящее сообщество

Evgeny GooDi

да пробовал, но что то он у меня не срабатывает.

так ты ошибку зачитай

источник

13:14пожаловаться #15

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

источник

13:14пожаловаться #16

АК

Артем Кулик in ReactiveX - русскоговорящее сообщество

Evgeny GooDi

он вернет Observable

Давайте разберемся сначала в чем проблема.
Как из потока данных получить 1 эммит?
Что вы хотите сделать? Вы хотите чтобы конвеер булочек выдал вам 1 коробку булочек? Или что

источник

13:15пожаловаться #17

Aleksey D. in ReactiveX - русскоговорящее сообщество

Evgeny GooDi

так тебе нужно Observable вернуть
выше ж подсказали заменить на flatMapSingle

источник

13:15пожаловаться #18

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

Задача такая.

источник

13:15пожаловаться #19

Aleksey D. in ReactiveX - русскоговорящее сообщество

а) поставить выше filter откидывать false значения
б) использовать flatMap и по условию отправить либо single.toObservable, либо Observable.never

источник

13:16пожаловаться #20