rx-java

17calore

2risposta

Perché si dovrebbe considerare l'utilizzo AndroidObservables in RxJava

Come capisco AndroidObservable aiuta a garantire che: un abbonato osserva sempre sul filo principale quando un frammento/attività è staccato/fermo, prima di arrestarsi osservazione immediatamente e le

7calore

1risposta

RxJava onErrorResumeNext()

Ho due osservabili (denominati A e B per semplicità) e un abbonato. Quindi, il Sottoscrittore sottoscrive A e se c'è un errore su A allora B (che è il fallback) entra in gioco. Ora, ogni volta che A c

16calore

1risposta

Come ottenere la notifica dell'azione di annullamento dell'iscrizione di un osservatore in un Osservabile personalizzato in RxJava

Sto provando a racchiudere un'API basata su listener-pattern su Observable. Il mio codice sembra quasi seguito. def myObservable = Observable.create({ aSubscriber -> val listener = {event ->

10calore

2risposta

Come utilizzare TestScheduler in RxJava

Come utilizzare RxJava's TestScheduler? Vengo da uno sfondo .NET ma lo TestScheduler in RxJava non sembra funzionare allo stesso modo dello scheduler di test in .NET rx. Ecco il codice di esempio che

7calore

3risposta

Combinazione di chiamate API con RX Java

Sono nuovo di RXJava e ho difficoltà a capire come concatenare il risultato delle chiamate API. Sto effettuando due chiamate API utilizzando Retrofit, A e B, che restituiscono entrambi un elenco di og

6calore

1risposta

Java enum senza istanze

In RXJava [1] v'è un enum [2] definita come public enum JavaFxObservable { ; // no instances public static void staticMethod() { // ... } } Qual è lo scopo di questa tecnica

27calore

4risposta

Osservabile che non passa nulla in onNext()

Avrei bisogno di un Osservabile, ad esempio per fornire un orologio di sistema, che non ha bisogno di passare nulla in onNext(). Non sono riuscito a trovare una firma che mi permettesse di farlo. Cert

15calore

1risposta

RxJava concatenamento degli osservabili e gestione degli errori (propagazione delle eccezioni personalizzate)

Ho 5 Observable s che sono concatenati con flatMap. Nel caso in cui i primi quattro Observable s producano un Exception Voglio propagare un diverso tipo di Exception al quinto. Come è stato realizzato

5calore

1risposta

RxAndroid: quando utilizzare bindActivity e perché?

È davvero necessario utilizzare AndroidObservable.bindActivity(...) in casi come l'attività seguente? Poiché è comunque necessario annullare l'iscrizione manualmente in onDestroy. Secondo this blog in

40calore

1risposta

Se viene effettuata la chiamata onComplete per un oggetto RxJava, devo annullare l'iscrizione manualmente di nuovo?

Sto usando un RxJava ReplaySubject nel mio frammento. Sto tentando di utilizzare ReplaySubject in un modo, in cui desidero che il soggetto esegua un processo fino al completamento (probabilmente oltre