RxJava - Reactive Extensions for the JVM - biblioteka do tworzenia programów asynchronicznych i opartych na zdarzeniach przy użyciu obserwowalnych sekwencji dla maszyny wirtualnej Java.
Pracuję nad siecią dla mojej aplikacji. Postanowiłem więc wypróbować Square's Retrofit . Widzę, że obsługują prosteCallback @GET("/user/{id}/photo") void getUserPhoto(@Path("id") int id, Callback<Photo> cb); i RxJava Observable @GET("/user/{id}/photo") Observable<Photo>...
W RxJava dostępnych jest 5 różnych harmonogramów : natychmiastowe () : Tworzy i zwraca program planujący, który natychmiast wykonuje pracę w bieżącym wątku. trampoline () : Tworzy i zwraca program planujący, który kolejkuje pracę nad bieżącym wątkiem do wykonania po zakończeniu bieżącej...
Chciałbym poznać różnicę między CompletableFuture, Futurea Observable RxJava. Wiem, że wszystko jest asynchroniczne, ale Future.get() blokuje wątek CompletableFuture podaje metody wywołania zwrotnego RxJava Observable--- podobnie jak w CompletableFutureprzypadku innych korzyści (nie jestem...
Kiedy używasz mapvs flatMapw RxJava ? Powiedzmy na przykład, że chcemy zmapować pliki zawierające JSON na ciągi zawierające JSON-- Używając map, musimy Exceptionjakoś sobie z tym poradzić . Ale jak?: Observable.from(jsonFile).map(new Func1<File, String>() { @Override public String...
Rxjava doc definicja switchmap jest dość niejasne i linki do tej samej strony jak flatmap. Jaka jest różnica między tymi dwoma
Czy strumienie Java 8 są podobne do obserwacji RxJava? Definicja strumienia Java 8: Klasy w nowym java.util.streampakiecie udostępniają interfejs API Stream do obsługi operacji w stylu funkcjonalnym na strumieniach
Patrzyłem na nową rx java 2 i nie jestem do końca pewien, czy rozumiem już ideę backpressure... Zdaję sobie sprawę, że my Observablenie mamy backpressurewsparcia i Flowableto je ma. Więc na podstawie przykładu powiedzmy, że mam flowablez interval: Flowable.interval(1, TimeUnit.MILLISECONDS,...
Czy ktoś mógłby wyjaśnić różnicę między Observable, Completable i Single w RxJava z jasnymi przykładami? W którym scenariuszu używamy jednego nad
Próbuję uaktualnić do wersji Retrofit 2.0 i dodać RxJava do mojego projektu na Androida. Wykonuję wywołanie API i chcę pobrać kod błędu w przypadku odpowiedzi błędu z serwera. Observable<MyResponseObject> apiCall(@Body body); A w wywołaniu
Zamierzam wysłać prostą metodę get na mój serwer (jest to aplikacja Rails) i uzyskać wynik za pomocą RxJava i Retrofit. To, co zrobiłem, to: Mój interfejs: public interface ApiCall { String SERVICE_ENDPOINT = "https://198.50.214.15"; @GET("/api/post") io.reactivex.Observable<Post>...
Używam rxjava w mojej aplikacji na Androida do asynchronicznej obsługi żądań sieciowych. Teraz chciałbym ponowić nieudane żądanie sieciowe dopiero po upływie określonego czasu. Czy istnieje sposób użycia retry () na Observable, ale ponowna próba tylko po pewnym opóźnieniu? Czy istnieje sposób,...
TL; DR Jak przekonwertować Task.whenAll(List<Task>)na RxJava? Mój istniejący kod używa Bolts do tworzenia listy zadań asynchronicznych i czeka, aż wszystkie te zadania zostaną zakończone, zanim wykonają inne kroki. Zasadniczo tworzy List<Task>i zwraca pojedynczy znak, Taskktóry...
Próbuję rozszyfrować następującą funkcję: Subscription getCar(id, Observer<Car> observer) { return getCarDetails(id, new Observer<CarDetails> { @Override onNext(CarDetails details) { observer.onNext(details.getCar()); } }); } Mam dobre wprowadzenie do rxjavy z...
Jakie są korzyści z używania w Schedulers.newThread()porównaniu Schedulers.io()z Retrofitżądaniami sieciowymi. Widziałem wiele przykładów, które używają io(), ale chcę zrozumieć, dlaczego. Przykładowa sytuacja: observable.onErrorResumeNext(refreshTokenAndRetry(observable))...