rx-java

6calore

3risposta

Ho un osservabile che produce dati da un flusso veloce da un cursore di database. Sto cercando di limitare l'output su un tasso di x articoli al secondo. Finora ho usato Callstack blocco come descritt

5calore

3risposta

Sequencing Scala Futures con il parallelismo limitato (senza fare in giro con ExecutorContexts)

Background: Ho una funzione: def doWork(symbol: String): Future[Unit] che avvia alcuni effetti collaterali per recuperare i dati e memorizzare, e completa un futuro quando il suo fare . Tuttavia, l'

6calore

1risposta

combineUltime emette solo quando uno degli stream cambia

Ho uno stream con valori frequenti e uno con uno più lento. Voglio combinarli, ma emetto solo un valore quando emette il più lento. Quindi, combineLatest non funziona. Come così: a1 a2 b1 (a2,b1)

13calore

2risposta

Richieste di rete RxJava e memorizzazione nella cache

Sto cercando un esempio di flusso che sto cercando di implementare con l'aiuto di RxJava. Supponiamo di voler mostrare un elenco di dati. Il flusso dovrebbe essere simile a questo: Leggere cache. Se c

6calore

1risposta

Come aggiornare osservabile in RxJava?

Ho un osservabile, che avvolge una richiesta HTTP mObservable = retryObservable(mService.getAddressList(getUserId(), true, 1, Integer.MAX_VALUE, "id", true) .map(r -> { return r.getItem

9calore

1risposta

Utilizzo di RxJava per recuperare oggetti, trasformare un elenco di contenuti e utilizzare l'elenco

Il problema di alto livello che sto cercando di risolvere è trasformare un elenco di oggetti contenuti in un oggetto recuperabile in un elenco di oggetti FooBar utilizzando RxJava. My (confuso) tentat

6calore

1risposta

Aggiunta di un pool di thread in un RxJava flusso

Mi chiedevo se posso usare il RxJava biblioteca al fine di aggiungere un po 'di concorrenza nel seguente caso d'uso: Fetch in sequenza una colonna String da un esistente ResultSet con un costume Obser

7calore

1risposta

Test Espresso con RxLoader

Ho un'attività che utilizza RxLoader per recuperare i dati dal server al momento della creazione dell'attività e popola una visualizzazione elenco. Ho anche il codice di prova che tenta di fare clic s

24calore

2risposta

Differenza tra Java Concurrency, Akka e RxJava?

Oggi ho scoperto che, per la concorrenza in java abbiamo una buona struttura come Akka e ho anche scoperto che, c'è un framework di programmazione reattivo come RxJava per l'esecuzione di multithreadi

18calore

2risposta

Ottenere informazioni di intestazione con RXJava e Retrofit

Sto provando a convertire la mia app che attualmente utilizza Retrofit, per utilizzare RX Java. Per gestire Pagination, tradizionalmente stavo afferrando l'URL nextPage dalle intestazioni di risposta.