rx-java

12Ciepło

2Odpowiedz

Operatory obsługi błędów Retrofit 2 i RxJava

Używam Retrofit 2 w moim projekcie z interfejsem Observable i wrapper Result. Przykład: @POST("api/login") Observable<Result<LoginResponse>> login(@Body LoginRequest request); muszę opakowanie Wyni

5Ciepło

1Odpowiedz

Efektywny sposób manipulowania wątkami RxJava

W moim projekcie muszę przetwarzać obiekty w różnych wątkach. Manipulować zachowanie Stream tworzę nowe obserwable zmienić swoje observeOn() ten sposób: apiService.getObjects(token) // Retrofit

9Ciepło

2Odpowiedz

Bieg histogram strumień z Rx

Mam następujący pojedynczy strumień list A B C A D B A C D I z tego strumienia, chciałbym strumień uruchomiony Ilość na literę (A,1) (A,1), (B,1) (A,1), (B,1), (C,1) (A,2), (B,1), (C,1)

5Ciepło

2Odpowiedz

RxJava Zwróć wartość subskrybowaną w funkcji

Z jakiegoś powodu, czasami chcę używać RxOperators zamiast normalnej java-metody przekształcania struktur danych, ponieważ jest ona czystsza i czystsza. Na przykład: Observable.from(listOfStrings) .f

5Ciepło

1Odpowiedz

AbstractMethodError podczas korzystania RxJavaCallAdapterFactory na Retrofit 2

otrzymuję ten błąd: FATAL EXCEPTION: main E/AndroidRuntime: java.lang.AbstractMethodError: abstract method not implemented at retrofit.RxJavaCallAdapterFactory.get(RxJavaCallAdapterFactory.java) at

7Ciepło

4Odpowiedz

Obserwowalne, ponownie w przypadku błędu i pamięci podręcznej tylko wtedy, gdy zakończone

możemy korzystać z pamięci podręcznej (operator), aby uniknąć wykonywania długiego zadania (żądania HTTP) wiele razy, i ponowne jej wynik: Observable apiCall = createApiCallObservable().cache(); // no

5Ciepło

2Odpowiedz

RXJava, jak spróbować uzyskać następną po X czasie

Chcę wykonać połączenie z serwisem internetowym za pomocą modernizacji co x sekund, aż stan Y zostanie podniesiony. Chcę uruchomić OrderApi.get po x sekundach, aż odpowiedź będzie pusta. public class

6Ciepło

1Odpowiedz

RxJava onCompleted i onTerminate na głównym wątku

Używam RxJava z Retrofit 2.0 na Androida dla żądań sieciowych. Kiedy tworzę obserwowalny, dodaję do niego następujące: observable = observable .observeOn(AndroidSchedulers.mainThread()) .sub

5Ciepło

3Odpowiedz

Prevent OnErrorNotImplementedException

chcę osiągnąć, że jeśli zgłoszę metodę Obervable.subscribe(Action1), nie rzucać OnErrorNotImplementedException wszędzie, ale jeśli zgłoszę Obervable.subscribe(Action1, Action1), druga akcja jest wywoł

7Ciepło

1Odpowiedz

Czy anulowanie subskrypcji jest bezpieczne w aplikacji RxJava?

Załóżmy, że mam następujący kod RxJava (który uzyskuje dostęp do DB, ale dokładny przypadek użycia nie ma znaczenia): public Observable<List<DbPlaceDto>> getPlaceByStringId(final List<String> stringId