rx-java
Фон У меня есть ряд наблюдаемых объектов RxJava (либо генерируемых из клиентов Джерси, либо заглушек с использованием Observable.just(someObject)). Все они должны излучать ровно одно значение. У меня есть компонентный тест, который высмеивает всех клиентов Jersey и использует Observable.just(someObject), и ...
Мои коллеги и я часто сталкиваемся с проблемой, и я надеюсь, что реактивное программирование может ее решить. Это, вероятно, потребует моей собственной реализации Operator или Transformer, хотя. Я хочу взять любые Observable<T> испускающие T элементы, но я хочу, чтобы оператор сгруппировал их на отобр...
Я работаю на сети для моего приложения. Поэтому я решил попробовать квадрат модернизация. Я вижу, что они поддерживают просто Callback @GET("/user/{id}/photo") void getUserPhoto(@Path("id") int id, Callback<Photo> cb); и RxJava Observable @GET("/user/{id}/photo") Observable<Photo> getUserPhoto...
The rxjava док определение switchmap довольно расплывчато и оно ссылается на та же страница как flatmap. В чем разница между двумя операторами?...
я смотрел на новый rx java 2, и я не совсем уверен, что понимаю идею ...
Я использую rxjava в моем Android-приложении для асинхронной обработки сетевых запросов. Теперь я хотел бы повторить неудачный сетевой запрос только после того, как прошло определенное время. есть ли способ использовать retry() на наблюдаемом, но повторить попытку только после определенной задержки? есть ли...
Я пытаюсь расшифровать следующую функцию: Subscription getCar(id, Observer<Car> observer) { return getCarDetails(id, new Observer<CarDetails> { @Override onNext(CarDetails details) { observer...
Я связываю асинхронные операции с помощью RxJava, и я хотел бы передать некоторую переменную вниз по течению: Observable .from(modifications) .flatmap( (data1) -> { return op1(data1); }) ... .flatmap( (data2) -> { // How to access data1 here ? return op2(data2); }) это п...
может ли кто-нибудь объяснить разницу между Observable, Completable и Single в RxJava с четкими примерами? в каком сценарии мы используем один над другими?...
примеры использования CompositeDisposable или Disposable в RxJava2. В RxJava 1 была CompositeSubscription, но этого нет в RxJava2, есть что-то CompositeDisposable в rxJava2. Как использовать CompositeDisposable или одноразовые в RxJava2....