RxJava - Reactive Extensions для JVM - библиотека для создания асинхронных и основанных на событиях программ с использованием наблюдаемых последовательностей для виртуальной машины Java.
Я работаю над созданием сетей для моего приложения. Поэтому я решил попробовать Square чрезвычайно Дооснащение . Я вижу, что они поддерживают простыеCallback @GET("/user/{id}/photo") void getUserPhoto(@Path("id") int id, Callback<Photo> cb); и RxJava's Observable @GET("/user/{id}/photo")...
В RxJava есть 5 разных планировщиков на выбор: немедленный () : создает и возвращает планировщик, который выполняет работу немедленно в текущем потоке. trampoline () : создает и возвращает планировщик, который ставит в очередь работу в текущем потоке, который будет выполнен после завершения текущей...
Я хотел бы знать разницу между CompletableFuture, Futureи Observable RxJava. Я знаю, что все они асинхронные, но Future.get() блокирует поток CompletableFuture дает методы обратного вызова RxJava Observable--- аналогично CompletableFutureс другими преимуществами (не уверен) Например: если клиенту...
Когда вы используете mapпротив flatMapв RxJava ? Скажем, например, мы хотим отобразить файлы, содержащие JSON, в строки, содержащие JSON-- Используя map, мы должны как-то разобраться Exception. Но как?: Observable.from(jsonFile).map(new Func1<File, String>() { @Override public String...
Rxjava док определение switchmap является довольно расплывчатым и ссылки на той же странице , как flatmap. В чем разница между двумя
Потоки Java 8 похожи на наблюдаемые RxJava? Определение потока Java 8: Классы в новом java.util.streamпакете предоставляют Stream API для поддержки операций в функциональном стиле над потоками элементов....
Я смотрел на новый rx java 2, и я не совсем уверен, что понимаю идею backpressure... Я знаю, что у нас есть Observableто, у кого нет backpressureподдержки, а у Flowableтого есть. Так на основе , например, позволяет сказать , что у меня есть flowableс interval: Flowable.interval(1,...
Может ли кто-нибудь объяснить разницу между Observable, Completable и Single в RxJava с четкими примерами? В каком сценарии мы используем одно по сравнению с
Я пытаюсь перейти на Retrofit 2.0 и добавить RxJava в свой проект Android. Я делаю вызов api и хочу получить код ошибки в случае ответа с ошибкой от сервера. Observable<MyResponseObject> apiCall(@Body body); И в вызове RxJava: myRetrofitObject.apiCall(body).subscribe(new...
Я собираюсь отправить простой метод get на свой сервер (это приложение Rails) и получить результат с помощью RxJava и Retrofit. Я сделал следующее: Мой интерфейс: public interface ApiCall { String SERVICE_ENDPOINT = "https://198.50.214.15"; @GET("/api/post") io.reactivex.Observable<Post>...
Я использую rxjava в своем приложении для Android для асинхронной обработки сетевых запросов. Теперь я хотел бы повторить неудачный сетевой запрос только по прошествии определенного времени. Есть ли способ использовать retry () для Observable, но повторить попытку только после определенной...
Я пытаюсь расшифровать следующую функцию: Subscription getCar(id, Observer<Car> observer) { return getCarDetails(id, new Observer<CarDetails> { @Override onNext(CarDetails details) { observer.onNext(details.getCar()); } }); } У меня есть хорошее введение в rxjava из...
Каковы преимущества использования Schedulers.newThread()vs Schedulers.io()в Retrofitсетевом запросе. Я видел много таких примеров io(), но хочу понять, почему. Пример ситуации: observable.onErrorResumeNext(refreshTokenAndRetry(observable)) .subscribeOn(Schedulers.newThread())...