Pytania otagowane jako rx-android

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 pracy. newThread () : Tworzy i zwraca harmonogram, …

253 java  multithreading  thread-safety  rx-java  rx-android 

Nie dostaję powodu, by używać RxJava w Androidzie i LiveData z Android Architectural Components. Bardzo pomocne byłoby wyjaśnienie przypadków użycia i różnic między nimi oraz przykładowy przykład w postaci kodu, który wyjaśnia różnice między nimi.

186 android  rx-java2  rx-android  reactive  android-architecture-components 

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 RxJava: myRetrofitObject.apiCall(body).subscribe(new Subscriber<MyResponseObject>() { @Override public void onCompleted() { } @Override public void onError(Throwable e) { …

108 android  retrofit  rx-java  android-networking  rx-android 

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> getPost(); } Mój model to: public class Post { @SerializedName("id") private String id; @SerializedName("body") …

96 retrofit  rx-java  retrofit2  rx-android  rx-java2 

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 jest oznaczony jako zakończony, gdy wszystkie zadania na liście zostaną ukończone, jak na przykładzie w …

91 java  rx-java  reactive-programming  rx-android 

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)) .subscribeOn(Schedulers.newThread()) .observeOn(AndroidSchedulers.mainThread())... vs observable.onErrorResumeNext(refreshTokenAndRetry(observable)) .subscribeOn(Schedulers.io()) .observeOn(AndroidSchedulers.mainThread())... Jednym z powodów, które widziałem, jest - newThread()tworzy nowy wątek dla każdej jednostki pracy. io()użyje puli wątków Ale jaki jest wpływ …

84 android  retrofit  rx-java  rx-android