rx-java

18Ciepło

2Odpowiedz

Uzyskiwanie informacji o nagłówku za pomocą RXJava i Retrofit

Próbuję przekonwertować moją aplikację, która obecnie używa funkcji Retrofit, do korzystania z Java RX. Aby obsłużyć paginację, tradycyjnie pobierałem adres URL strony next z nagłówków odpowiedzi. @Ov

5Ciepło

3Odpowiedz

Sekwencjonowanie Scala Futures z ograniczonym równoległości (bez aprowizacji z ExecutorContexts)

Tło: Mam funkcję: def doWork(symbol: String): Future[Unit] która inicjuje pewne skutki uboczne, aby pobrać dane i przechowywać je i uzupełnia przyszłego gdy jego done . Jednak infrastruktura zaplecz

6Ciepło

1Odpowiedz

Jak odświeżyć obserwowalne w RxJava?

Mam obserwowalne, który owija żądanie HTTP mObservable = retryObservable(mService.getAddressList(getUserId(), true, 1, Integer.MAX_VALUE, "id", true) .map(r -> { return r.getItems();

6Ciepło

2Odpowiedz

Android: pobieranie z serwera za pomocą Retrofit

Buduję grę dla dwóch graczy na Androida. Gra działa odwrotnie, więc gracz 1 czeka, aż gracz 2 dokona swojego wejścia i na odwrót. Mam serwer WWW, na którym uruchamiam interfejs API w ramach Slim. Na k

18Ciepło

2Odpowiedz

Jak komponować Observables w celu uniknięcia podanych zagnieżdżonych i zależnych wywołań zwrotnych?

W this blog, podaje this (skopiować/wkleić następujący kod) przykład piekła oddzwonienia. Nie ma jednak wzmianki o tym, w jaki sposób można wyeliminować problem za pomocą rozszerzeń reaktywnych. Tak w

11Ciepło

2Odpowiedz

Android rxJava Obsługa błędów z modernizacją

używam nowszej java RX gdzie zamiast Observable.create(new Observable.OnSubscribeFunc<T>() {...}); ten jest używany: (ze względu na amortyzację) Observable.create(new Observable.OnSubscribe<T>() {..

6Ciepło

1Odpowiedz

CombineLatest emituje tylko wtedy, gdy zmienia się jeden ze strumieni

Mam strumień z częstymi wartościami i jeden z wolniejszymi. Chcę je łączyć, ale emitować wartość tylko wtedy, gdy emituje wolniejszą. Więc combineLatest nie działa. tak: a1 a2 b1 (a2,b1) a3 a4 a

22Ciepło

3Odpowiedz

RxJava - pobierz każdy element z listy

Mam metodę zwracającą wartość Observable<ArrayList<Long>>, która jest identyfikatorem niektórych elementów. Chciałbym przejrzeć tę listę i pobrać każdy element przy użyciu innej metody, która zwraca O

16Ciepło

2Odpowiedz

Jak zamienić "if statement" na rx-java, aby uniknąć piekła wywołania zwrotnego?

Próbuję zastąpić mój kod przez rx-java. (Jest to bardzo mały kod.) Jest gotowy i działa. Ale chcę wiedzieć ... Czy to dobry styl Rx? Jeśli nie dobry, proszę wskazać zły punkt Poniżej jest mój kod, któ

24Ciepło

2Odpowiedz

Różnica między Java Współbieżność, Akka i RxJava?

Dziś znalazłem, że dla współbieżności w java mamy dobre ramy takie jak Akka i odkryłem również, że istnieją reaktywne ramy programistyczne, takie jak RxJava do wykonywania multithreading w aplikacji.