rx-java2

1зной

2ответ

Почему doAfterTerminate() отсутствует в Single <> в RxJava 2?

Я просто изучаю RxJava 2, и после того, как код рефакторинга использовать Single вместо Observable, я обнаружил, что Single не реализует doAfterTerminate(). Это выглядит для меня быть упущение, так ка

2зной

2ответ

Список фильтров RxJava2 <Object>

Я пытаюсь отфильтровать список с RxJava2 таким образом, чтобы каждый элемент (объект) в списке должен пройти проверку проверки, и я получаю результирующий список только с тегами, которые проходят этот

0зной

1ответ

Query RxJava2 Db в другой предмет

В моем проекте Android я сильно полагаюсь на RxJava2, SqlBrite (с RxJavaInterop) и SqlDelight. У меня есть один поток RX, который должен идти бесконечно (пока мое обслуживание не прекратится), и на не

0зной

2ответ

Исключение не распространяется на onError() при броске из doOnSubscribe()

Существует PublishProcessor, который вызывает оператор .doOnSubscribe(checkCondition) для выполнения определенной проверки. checkCondition предназначен для выброса UnsupportedOperationException, котор

0зной

3ответ

RxJava2 flatMap создает повторяющиеся события

Я относительно новичок в RxJava2, и у меня возникают некоторые странные поведения, поэтому вполне вероятно, что я использую инструмент не по-другому. Это довольно большой проект, но я отделил фрагмент