rx-java

Kiedy należy używać RxJava Observable i kiedy proste Callback na Androida?

Pracuję nad siecią dla mojej aplikacji. Postanowiłem więc wypróbować modernizację Square . Widzę, że wspierają proste Callba ... owym projekcie Jake ' a Whartona U2020 . Ale zasadniczo pytanie pozostaje takie samo-kiedy należy użyć jednej drogi lub inne?

Różnica między CompletableFuture, Future I RxJava ' s Observable

Chciałbym poznać różnicę między CompletableFuture,Future oraz Observable RxJava. Wiem, że wszystkie są asynchroniczne, ale ... onicznego wykonywania. Naprawdę zainteresowany wiedz, jak rozwiązać ten problem. Trudno mi było to zrozumieć z dokumentacji.

Przypadki użycia dla Terminatorów RxJava

W RxJava jest 5 różnych schedulerów do wyboru: Immediate () : tworzy i zwraca Scheduler, który natychmiast wykonuje p ... t wywoływać computation () podczas wykonywania pracy w IO? dlaczego źle jest wywoływać io () podczas pracy obliczeniowej?

Różnica pomiędzy strumieniami Java 8 a RxJava

Czy strumienie Java 8 są podobne do RxJava observables? Definicja strumienia Java 8: Klasy w nowym pakiecie java.util.stream dostarczają Stream API do obsługa operacji w stylu funkcjonalnym na strumieniach elementów.

Kiedy używasz map vs flatMap w RxJava?

Kiedy używasz map vs flatMap w RxJava? Powiedzmy na przykład, że chcemy mapować pliki zawierające JSON na łańcuchy zawierają ... p (nie werbalność). Nie widziałem żadnych najlepszych praktyk na ten temat i jestem ciekaw, jak to jest stosowane w praktyce.

Jaka jest różnica między flatmap a switchmap w RxJava?

RxJava Doc definicja switchmap jest dość niejasna i łączy się z tą samą stroną Co flatmap. Jaka jest różnica między tymi dwoma operatorami?

Połącz listę obserwowanych i poczekaj, aż wszystkie zostaną ukończone

TL; DR Jak przekonwertować Task.whenAll(List<Task>) na RxJava? Mój istniejący kod wykorzystuje śruby do tworzenia lis ... mi, jeśli jest to oczywiste pytanie lub wyjaśnione gdzieś w dokumentach; próbowałem szukać. Każda pomoc będzie mile widziana.

Uzyskaj kod statusu odpowiedzi za pomocą Retrofit 2.0 i RxJava

[3]}próbuję uaktualnić do Retrofit 2.0 i dodać RxJava w moim projekcie android. Wykonuję połączenie api i chcę pobrać kod błę ... istniał i możemy uzyskać status wykonując: error.getResponse().getStatus() Jak to zrobić z Retrofit 2.0 używając RxJava?

rxjava: Czy mogę użyć retry (), ale z opóźnieniem?

Używam rxjava w mojej aplikacji na Androida do asynchronicznie obsługiwania żądań sieciowych. Teraz chciałbym ponowić próbę n ... piej, jeśli opóźnienie nie zostało zastosowane po błąd, ale zamiast przed retry (ale nie przed pierwszą próbą, oczywiście).

RxJava

Potrzebuję pomocy w implementacji równoległych wywołań asynchronicznych w RxJava. Wybrałem prosty przypadek użycia, w którym ... żej powinien wyglądać bardziej pionowo ułożony. Połączenia do recenzji i obrazów powinny być równoległe Dzięki anand raman

Jaka jest różnica między obserwowalnym, kompletnym i pojedynczym w RxJava

Czy ktoś może wyjaśnić różnicę między Obserwowalnymi, kompletnymi i pojedynczymi w RxJava jasnymi przykładami? W którym scenariuszu używamy jednego nad drugim?

EventBus / PubSub vs (Reactive extensions) RX w odniesieniu do przejrzystości kodu w pojedynczej aplikacji z gwintem

Obecnie używam architektury / wzorca EventBus/ pubsub ze scalą (i JavaFX) do zaimplementowania prostej aplikacji organizując ... RXJava byłaby lepsza niż zwykły EventBus w przypadku jednowątkowej aplikacji, w której nie są wykonywane operacje blokowania.

Obserwowalne vs Flowable rxJava2

[[15]}Szukałem nowego RX java 2 i nie jestem do końca pewien, czy Rozumiem już ideę backpressure... Zdaję sobie sprawę, że ... z zarządzania buffer? A może z drugiej strony, jakie korzyści dają mi backpressure na rzecz zarządzania i obsługi konsumpcji?

RxJava i buforowane dane

Wciąż jestem całkiem nowy w RxJava i używam go w aplikacji na Androida. Czytałem o tym, ale nadal czuję, że coś mi umyka. Ma ... ji, takich jak flatmap, merge, a nawet tematy, ale z jakiegoś powodu mam problem z połączeniem kropek. Jak mogę to zrobić?

Jak stosować CompositeDisposable of RxJava 2?

Przykłady użycia CompositeDisposable lub Disposable w RxJava2. W RxJava 1 był zapis CompositeSubscription, ale tego nie ma w RxJava2, jest coś CompositeDisposable w rxJava2. Jak stosować CompositeDisposable lub Disposable w RxJava2.

Różnica między RxJava API i Java 9 Flow API

Wydaje się, że na każdej iteracji Javy w ostatnich kilku ważnych wydaniach pojawiają się stale nowe sposoby zarządzania współ ... ? Dlaczego ktoś miałby używać biblioteki Java 9 Flow zamiast znacznie bardziej zróżnicowanej biblioteki RxJava lub odwrotnie?

RxJava obserwując na wywołanie / subskrybowanie wątku

Mam pewien problem jak działa subscribeOn / observeOn w RxJava. Stworzyłem prostą aplikację z observable, która emituje nazwy ... z bieżącego wątku? Również, dowiedziałem się, że po uruchomieniu tego kodu, to nigdy się nie kończy i nie wiem dlaczego? :(

Jak można zrezygnować z PublishSubject i BehaviorSubject?

POD subjects masz klasy takie jak PublishSubject i BehaviorSubject, które przypuszczam, że można opisać jako jakąś użyteczną ... k można zrezygnować z tych tematów? Nie ma metody unsubscribe i wywołanie onCompleted Kończy obserwowalne całkowicie prawda?

Jak utworzyć obserwowalne Z zdarzenia onclick Android?

Jestem nowy w programowaniu reaktywnym. Więc mam problem przy tworzeniu strumienia Z zdarzenia, jak onClick, ontouch... Czy ktoś może mi pomóc rozwiązać ten problem? Dzięki.

Uchwyt Przywoławczy z RxJava

Używam Retrofit + RxJava w aplikacji na Androida i zastanawiam się, jak poradzić sobie z paginacją API do połączeń łańcuchowy ... ść until to last page. Jest jakiś dobry sposób, aby to osiągnąć? Próbowałem połączyć kilka flatMaps () , ale bez powodzenia.