rx-java

9Ciepło

3Odpowiedz

Wykonywanie N sekwencyjnych wywołań api za pomocą RxJava i Retrofit

Mam listę plików, które chciałbym przesłać do backendu z urządzenia z systemem Android. Z powodu ograniczeń pamięci chciałbym wykonać drugie wywołanie API tylko po pierwszym zakończeniu, trzecim po dr

13Ciepło

1Odpowiedz

Jak działają funkcje RxJava doOnError i onErrorReturn?

zrobiłem te testy jednostkowe, a wynik nie jest to, czego się spodziewałem w ogóle: // This one outputs "subscribe.onError" @Test public void observable_doOnError_subscribingToError() throws Interru

9Ciepło

3Odpowiedz

Jak wykonać wykonanie FlatMap na wątku tła

Używam Retrofit i RxJava do wykonywania niektórych zadań w tle. Kod wygląda następująco: public class MyLoader{ public Observable<MyData> getMyData(){ return setupHelper().flatMap(new Func1

8Ciepło

2Odpowiedz

Modernizacja nie jest w stanie stworzyć adapter połączenia

To mój UserService Interfejs @GET(Constants.Api.URL_LOGIN) String loginUser(@Field("email") String email, @Field("password") String pass, @Field("secret") String secret, @Field("device_id") Strin

13Ciepło

1Odpowiedz

Jak zarządzać DialogFragment z RxJava?

Próbuję ustalić, czy możliwe jest utworzenie możliwego do zaobserwowania DialogFragment. Zasadniczo chcę, aby być w stanie: Tworzenie i pokazać DialogFragment Wracaj RX Observable które mogą być subsk

11Ciepło

3Odpowiedz

ReactXX concat nie produkuje OnNext z pierwszego obserwowalnego, jeśli sekunda nie powiedzie się natychmiast

Dołączam dwa obserwowalne, aby wyświetlić dane z pamięci podręcznej, a po pierwsze rozpocząć ładowanie danych z sieci i pokazywać zaktualizowane dane. Observable.concat( getContentFromCache.subscr

5Ciepło

1Odpowiedz

Kliknięcia przycisku rozwijania za pomocą Rx

Próbuję zrobić prosty "przycisk debouncer", który zliczy kliknięcia filtrowane i wyświetli je poprzez TextView. Chcę filtrować kliknięcia typu "szybki/spam" w taki sposób, że kliknięcia z mniej niż 30

10Ciepło

1Odpowiedz

RxJava - Czy pamięć podręczna() jest taka sama jak funkcja odtwarzania()?

Zastanawiam się, czy istnieje operator cache(), który może buforować x liczbę emisji, ale także wygasać po określonym czasie (np. 1 minuta). Szukałem czegoś podobnego ... Observable<ImmutableList<MyTy

5Ciepło

2Odpowiedz

RxJava dla Androida: Expose wyjątek i ponowić (z opóźnieniem)

Mam następujący Obserwowalne który wykona odpocząć-Call z modernizacją co 30 sekund: Subscription subscription = Observable.interval(0, REFRESH_INTERVAL, TimeUnit.SECONDS) .concatMap(new Func1<L

17Ciepło

3Odpowiedz

Używanie RxJava i Okhttp

Chcę zażądać adresu URL za pomocą okhttp w innym wątku (jak wątek IO) i uzyskać Response w głównym wątku systemu Android, ale nie wiem, jak utworzyć Observable.