Вопросы с тегом 'rx-java'

RxJava - Reactive Extensions для JVM - библиотека для составления асинхронных и основанных на событиях программ с использованием наблюдаемых последовательностей для виртуальной машины Java.
8

Когда следует использовать RxJava Observable и когда просто обратный вызов на Android?

Я работаю над сетью для своего приложения. Поэтому я решил попробовать Square Retrofit. Я вижу, что они поддерживают простой Callback @GET("/user/{id}/photo") void getUserPhoto(@Path("id") int id, Callback<Photo> cb); и RxJava Observable @G...
19 февр. '14 в 19:25
3

Варианты использования для планировщиков RxJava

В RxJava есть 5 разных планировщиков на выбор: немедленный(): создает и возвращает планировщик, который немедленно запускает работу в текущем потоке. trampoline(): создает и возвращает планировщик, который работает в очереди на текущий поток,...
07 июл. '15 в 18:06
2

Разница между CompletableFuture, Future и RxJava Observable

Я хотел бы знать разницу между CompletableFuture, Future и Observable RxJava. Я знаю, что все они асинхронные, но Future.get() блокирует поток CompletableFuture предоставляет методы обратного вызова RxJava Observable --- похож на CompletableFutu...
11 февр. '16 в 2:37
7

В чем разница между планшетами и коммутационной панелью в RxJava?

Определение switchmap rxjava doc довольно расплывчато и ссылается на ту же страницу, что и на планшет. В чем разница между двумя операторами?
27 янв. '15 в 16:51
8

Когда вы используете карту против flatMap в RxJava?

Когда вы используете map vs flatMap в RxJava? Скажем, например, мы хотим отобразить файлы, содержащие JSON, в строки, содержащие JSON - Используя карту, мы должны как-то разобраться с Исключением. Но как?: Observable.from(jsonFile).map(new Func1&l...
03 апр. '14 в 19:26
7

Разница между потоками Java 8 и наблюдаемыми значениями RxJava

Являются ли потоки Java 8 похожими на наблюдаемые RxJava? Определение потока Java 8: Классы в новом пакете java.util.stream предоставляют Stream API для поддерживать функциональные операции над потоками элементов.
13 мая '15 в 13:54
3

Наблюдаемый против Flowable rxJava2

Я смотрел новый rx java 2, и я не совсем уверен, что я больше понимаю идею backpressure... Я знаю, что у нас есть Observable, у которого нет поддержки backpressure и Flowable, которая имеет его. Итак, на примере, скажем, у меня Flowable с interv...
29 окт. '16 в 20:19
14

rxjava: Можно ли использовать функцию retry(), но с задержкой?

Я использую rxjava в своем Android-приложении для асинхронной обработки сетевых запросов. Теперь я хотел бы повторить неудачный сетевой запрос только через некоторое время. Можно ли использовать функцию retry() в Observable, но повторить только посл...
27 февр. '14 в 11:00
3

Не удалось создать адаптер вызова для io.reactivex.Observable

Я собираюсь отправить простой метод get на мой сервер (это приложение Rails) и получить результат с помощью RxJava и Retrofit. То, что я сделал, это: Мой интерфейс: public interface ApiCall { String SERVICE_ENDPOINT = "https://198.50.214.15"; ...
16 апр. '17 в 5:34
1

Модернизация с помощью Rxjava Schedulers.newThread() vs Schedulers.io()

Каковы преимущества использования Schedulers.newThread() vs Schedulers.io() в сетевом запросе Retrofit. Я видел много примеров, которые используют io(), но я хочу понять, почему. Пример ситуации: observable.onErrorResumeNext(refreshTokenAndRetry(o...
29 окт. '15 в 13:41
6

Объедините список Observables и дождитесь завершения всех завершенных

TL; DR Как преобразовать Task.whenAll(List<Task>) в RxJava? В моем существующем коде используются болты для создания списка асинхронных задач и ожидания до завершения всех этих задач перед выполнением других действий. По существу, он создае...
12 февр. '16 в 8:28
7

В RxJava, как передать переменную вдоль цепочки наблюдаемых?

Я связываю операции async с использованием RxJava, и я хотел бы передать некоторую переменную ниже по течению: Observable .from(modifications) .flatmap( (data1) -> { return op1(data1); }) ... .flatmap( (data2) -> { // How t...
27 янв. '15 в 17:12
2

Как использовать CompositeDisposable для RxJava 2?

В RxJava 1 была CompositeSubscription, но ее нет в RxJava2, в rxJava2 есть что-то CompositeDisposable. Как использовать CompositeDisposable или Disposable в RxJava2?
29 авг. '16 в 10:17
2

В чем разница между Observable, Completable и Single в RxJava

Может ли кто-нибудь объяснить разницу между Observable, Completable и Single in RxJava с четкими примерами? В каком сценарии мы используем один над другими?
13 мар. '17 в 6:50
4

В чем разница между наблюдателем и подписчиком?

Я пытаюсь расшифровать следующую функцию: Subscription getCar(id, Observer<Car> observer) { return getCarDetails(id, new Observer<CarDetails> { @Override onNext(CarDetails det...
27 дек. '14 в 4:03