Описание тега rx-java
RxJava - Reactive Extensions для JVM - библиотека для создания асинхронных и основанных на событиях программ с использованием наблюдаемых последовательностей для виртуальной машины Java.
1
ответ
Почему моя подписка никогда не завершается?
Я пытаюсь узнать о rxJava и реактивном программировании в контексте Android, и я чувствую, что я почти на месте, я просто не могу понять всю картину, чтобы полностью понять, что я делаю. У меня есть код ниже, который получает список экземпляров клас…
29 июн '15 в 11:59
0
ответов
RX Java - наблюдать один побочный эффект на основной поток очень медленно
Я делаю следующее в моем приложении (см. Комментарии, чтобы увидеть, что происходит, логика довольно проста): // 1) import folders from system importObservable // 2) emit all folders as list // => 1 item is emitted only // => flatMap can be us…
14 окт '16 в 07:47
1
ответ
Эквивалент rxjs concatAll() в rxjava
Моя цель - моделировать события с некоторой случайной (предопределенной) задержкой. Я моделирую события в RxJs, как показано ниже: var events = [ {id: 1, qty: 23, delayMs: 0}, {id: 1, qty: 231, delayMs: 3}, {id: 1, qty: 232, delayMs: 1}, {id: 1, qty…
28 дек '15 в 13:00
2
ответа
RxJava заставляет retryWhen() запускать метод onError()
У меня есть следующий класс с реализацией RxJava для загрузки двух ресурсов из API. Я делаю некоторые rx, чтобы позволить ему повторить или повторить, если он не отвечает требованиям API / соединения. Тем не менее, я не могу заставить retryWhen() за…
30 сен '16 в 07:31
1
ответ
Противодавление в RxJava2
Предполагается, что у меня есть 1 миллион строк записей в базе данных. Затем я использую Flowable (вместо Observable) для чтения записей, затем записываю их в файл с медленным шифрованием (запись намного медленнее, чем чтение). Если я не использую "…
05 сен '17 в 11:07
1
ответ
Как вы делаете продолжения с RxJava Observables?
Итак, у меня есть одна асинхронная операция A это зависит от секунды, B, Как сделать B продолжением A, как это было бы с тогдашней функцией Javascript Promises или с ContinueWith в.NET TPL? Давайте возьмем сценарий с Android, где у меня есть две кон…
24 ноя '14 в 14:22
2
ответа
Наблюдаемый - подпишитесь двумя способами
У меня есть Observable лайк: Observable<Integer> dropdownChange = ReactiveUIObservables.selectionChange(myDropdown) Теперь у меня есть: LifecycleObservable.bindFragmentLifecycle(lifecycle(), dropdownChange) .ObserveOn(AndroidSchedulers.mainThr…
31 окт '16 в 11:25
1
ответ
Ожидание пары наблюдаемых, чтобы закончить с / без последовательности Retrofit2 с rxjava - Android
Я использую модификацию 2 с расширением rxjava У меня есть 3 Observables, которые будут делать 3 разные вещи Observable<String> observable1 = RetrofitInterface.GetByID(id); Observable<String> observable2 = RetrofitInterface.GetByKey(key)…
14 июн '16 в 12:26
5
ответов
IllegalArgumentException: не удалось найти адаптер вызова для rx. Наблюдаемый RxJava, Retrofit2
Я получаю вышеуказанную ошибку при вызове остальных API. Я использую как retrofit2 и RxJava. ServiceFactory.java public class ServiceFactory { public static <T> T createRetrofitService(final Class<T> clazz, final String endpoint){ Retrof…
05 фев '16 в 20:43
2
ответа
Множество наблюдаемых одним подписчиком
Мне нужно использовать события из нескольких источников. Количество источников варьируется, источник может быть динамически добавлен или удален. Поскольку я хочу возможность менять набор источников "на лету", без необходимости повторной подписки, me…
05 июн '17 в 15:41
1
ответ
RxJava 2: Retry Completable при отправке уведомлений о повторных попытках подписчикам
Я новичок в RxJava 2 и хочу повторить Completable вызов сервера API до успешного завершения при отправке уведомлений о попытках повторных попыток, чтобы мой пользовательский интерфейс мог отображать состояние повторных попыток для пользователя. Что-…
24 фев '17 в 17:59
1
ответ
Как обрабатывать элементы, испускаемые Observable с доступом к значениям из другого?
Мне нужно выполнить асинхронный call_1Лови свою Наблюдаемую reply_1затем сделайте еще одну асинхронную операцию call_2 и при обработке его reply_2 Мне также нужен доступ к reply_1, Я пробовал что-то вроде: public rx.Observable<Game> findGame(l…
02 окт '14 в 16:51
0
ответов
Тайм-аут DeferredResult тайм-аут
У меня есть наблюдаемое и, как это может занять много времени, я возвращаю весну DeferredResult, Это логика контроллера, которую я использую: public DeferredResult<ResponseEntity<InputStreamResource>> getSomeFile() { DeferredResult<Re…
25 окт '16 в 06:57
1
ответ
Есть ли "полный" набор функций / операторов для FRP?
Функциональное реактивное программирование - это подход к определению побочных программ чисто функциональным способом. Недавно я использовал rxscala, который является портом порта Java/Scala ReactiveX. Он основан на концепции Observables, которые мо…
15 июн '15 в 18:19
2
ответа
Об использовании метода подписки с возвратом подписчика
Интересно, почему subscribeWith Метод возвращает подписчика, но не является строго одноразовым или, может быть, подпиской. Я думаю, что subscribeWith метод был разработан для использования RxJava 1.x subscribe метод, который возвращает подписку. Поэ…
12 окт '16 в 07:35
1
ответ
Как можно условно добавить асинхронную операцию в середине потока RxJava?
Вот упрощенная версия того, что я пытаюсь сделать (используя Kotlin и RxJava) makeServerCall() .doOnNext { doStuff(it) } //TODO: if it == 0, call asyncOperation() and wait for its callback to fire //before running the rest of the stream. Otherwise i…
14 сен '17 в 16:27
2
ответа
Rx Observables: испускать дополнительный предмет для каждого оригинального предмета, уменьшать его до другого типа, потреблять
У меня проблемы с выполнением следующих действий с использованием Couchbase Java client 2.2.2 и Rx Observables 1.0.15: У меня есть список строк, которые являются именами документов Наряду с каждым оригинальным документом для имени документа я хотел …
13 дек '15 в 21:53
1
ответ
RxJava2: выполнить асинхронную функцию для каждого элемента в списке и ожидать обратного вызова
Я борюсь с RxJava2. Я хочу выполнить функцию для каждого элемента списка. Эта функция: public void function(final Result result) { FirebaseFirestore.getInstance().collection(COLLECTION_NAME).document(result.getId()).get().addOnSuccessListener(new On…
28 июл '18 в 13:51
1
ответ
Интервал rxjava в сочетании с другим наблюдаемым
У меня есть наблюдаемое (что горячо), которое делает что-то через системный процесс, и я бы хотел, чтобы интервал также работал, пока наблюдаемый процесс не достигнет полного завершения. Я вижу оператор интервала: http://reactivex.io/documentation/o…
20 мар '17 в 17:42
0
ответов
RxAndroid: onCompleted не вызывается
Я использую библиотеки rx в моем приложении, чтобы вызвать REST API на моем сервере и показать результаты на экране. Я также следую шаблону дизайна MVP. Так что у меня есть классы Presenter и Interactor. В MainInteractor.java у меня есть следующий м…
01 фев '18 в 08:09