rx-java2

4зной

4ответ

В чем разница между возможностями rxjava2 и необязательными?

Док говорит Концептуально, это объединение одного и Completable обеспечение означает, чтобы захватить образец излучения там, где может быть 0 или 1 элемент или ошибка сигнализируют какой-реактивного и

0зной

2ответ

Android RxJava2: как настроить правильный асинхронный наблюдаемый потребительский REST API?

Мой код: RestClient client = new RestClient(); Disposable subscribe = client.getApiMovie().getTopRated() .subscribeOn(Schedulers.newThread()) .observeOn(AndroidSchedulers.mainThr

0зной

2ответ

RX Java 2, Observable, который принимает новые значения, которые необходимо добавить

Я ищу, чтобы создать класс LocationHandler, который возвращает observable<Location>, я могу отправить новое местоположение и подписчики получить последнее добавленное и любые последующие значения. Я н

0зной

1ответ

RxJava 2: всегда отписаться от планировщика .subscribeOn (..)?

У меня есть Observable<String>, который выполняет некоторую работу. После того, как его сделать, он закрывает соединение (через .setDisposable(Disposables.fromAction(logic*);. Проблема, мне нужно это

0зной

1ответ

Использование процессора реактивных потоков с RxJava 2.0

У меня есть org.reactivestreams.Processor, который я бы хотел использовать с RxJava 2.0. Однако, хотя есть преобразования для интеграции org.reactivestreams.Publisher с RxJava, например io.reactivex.F

2зной

1ответ

AutoCompleteTextView с Модернизированный 2 RxJava и RxBinding

Я новичок в Rx мире и попытаться реализовать мой AutoCompleteTextView с RxJava, RxBinding и Retrofit 2. Вот что я придумал что хлопотно: (. Может быть, я не делаю это в правильном направлении) У меня