rx-java2

0зной

1ответ

Как кэшировать реактивный издатель вроде Observable?

Я пытаюсь понять, что произойдет, если я кэширую результат метода, возвращающего холодный наблюдаемый? Поток еще не материализован, так что собственно кеш содержит? Я попытался выяснить использование

1зной

1ответ

RxJava Trouble testing Presenter в Android

Привет, я хочу протестировать презентацию Android, используя mockito, и у меня много проблем. Вот код, я хочу, чтобы тест: public class SignUpPresenter extends BasePresenter { private static fina

3зной

1ответ

RxJava JUnit тест с Модернизированный бросает NullPointerException

У меня есть вызов API retrofit2 public interface FeedService { @GET("/api/v1/feeds") Observable<FeedResponse> getFeeds(@Query("page") Integer pageNumber, @Query("cats") String

0зной

1ответ

Как принять последний элемент или запросить еще раз, если ошибка (RxJava + Retrofit)

Имейте реализацию конечных точек API через Retrofit, которая возвращает Observable. Observable<Post> postObservable = sampleApi.getPost(1); нужно что-то подобный cache оператора ого, но без кэширова

0зной

1ответ

Что эквивалентно однопоточному ExecutorService в RxJava?

Я хотел бы использовать RxJava вместо моего однотридовой ExecutorService: private ExecutorService executor = Executors.newSingleThreadExecutor(); executor.submit(/* ... */); Я задавался вопросом, ч

0зной

2ответ

Как собрать выбросы двух наблюдаемых в разные списки? используя RxJava?

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

-3зной

1ответ

NetworkOnMainThreadException когда Наблюдаемые subscrible rxjava

Я работаю с Rxjava2, Я использую flatmap в RxJava с ниже структуры: Observable1.flatmap() и вернуться к наблюдаемым 2. ниже кодов: getApi().createUser(os, deviceToken) .compose(view.regisObserv