rx-java

9Ciepło

1Odpowiedz

Retrofit/Rxjava i usługi oparte na sesji

Wdrażam usługi sesyjne. Wszystkie żądania muszą być subskrybowane z parametrem sesji cookie, który z kolei jest pobierany z osobnym interfejsem do odpoczynku. Tak więc podstawowym przepływem pracy był

7Ciepło

2Odpowiedz

Robolectric + OkHttp + modernizacja + test jednostki rxJava

Próbuję napisać test jednostkowy dla kawałka kodu z robolectric. Problemem jest to, że muszę udawać połączenia http ale wydaje fałszywe warstwę, która robolectric za to działa tylko z Apache HttpClien

40Ciepło

1Odpowiedz

Jeśli wywołanie onComplete jest wykonywane dla podmiotu RxJava, czy muszę ręcznie anulować subskrypcję ponownie?

Używam RxJava ReplaySubject w moim Fragment. Próbuję użyć ReplaySubject w sposób, w którym chciałbym, aby Temat wykonywał proces aż do zakończenia (prawdopodobnie poza żywotność fragmentu). Po zakończ

17Ciepło

2Odpowiedz

Dlaczego należy rozważyć użycie AndroidObservables w RxJava

jak rozumiem AndroidObservable pomaga zapewnić, że: Abonent zawsze zauważa się na głównym wątku gdy fragment/działalności jest odłączony/zatrzymał się, a następnie zatrzymuje obserwacyjnych natychmias

7Ciepło

1Odpowiedz

RxJava onErrorResumeNext()

Mam dwie obserwowalne (o nazwie A i B dla uproszczenia) i jeden subskrybent. Tak więc subskrybent subskrybuje A, a jeśli wystąpi błąd na A, wtedy B (który jest awaryjnym) wciąga. Teraz, gdy A trafi bł

16Ciepło

1Odpowiedz

Jak otrzymać powiadomienie o akcji wypisania obserwatora w niestandardowym Obserwowalnym w RxJava

Próbuję zawinąć niektóre API oparte na wzorzec słuchacza do obserwowalnego. Mój kod wygląda z grubsza na następujące. def myObservable = Observable.create({ aSubscriber -> val listener = {event -

10Ciepło

2Odpowiedz

Jak używać TestScheduler w RxJava

Jak korzystać z RxJava's TestScheduler? Pochodzę z tła .NET, ale TestScheduler w RxJava nie wydaje się działać tak samo jak harmonogramu testów w .NET rx. Oto przykładowy kod, który chcę przetestować

6Ciepło

1Odpowiedz

Java enum bez przypadkach

W RXJava [1] nie jest enum [2] określono jako public enum JavaFxObservable { ; // no instances public static void staticMethod() { // ... } } Jaki jest cel tej techniki przy

15Ciepło

1Odpowiedz

Obserwowanie łańcucha RxJava i obsługa błędów (niestandardowa propagacja wyjątków)

Mam 5 Observable s, które są powiązane z flatMap. W przypadku pierwszych czterech Observable s produkcji Exception chcę propagować inny rodzaj Exception do piątego. Jak to osiągnąć? Dzięki. P.S. Dosze

53Ciepło

2Odpowiedz

RxJava Fetching Observables Równolegle

Potrzebuję pomocy w implementacji równoległych połączeń asynchronicznych w RxJava. Podjąłem prosty przypadek użycia, w którym PIERWSZE połączenie pobiera (raczej wyszukuje) listę produktów (Tafli) do