reactive-programming

5calore

3risposta

RxJava Osservabile ricevere una notifica sulla prima emissione

ho tre osservabili che combino con combineLastest: Observable<String> o1 = Observable.just("1"); Observable<String> o2 = Observable.just("2"); Observable<String> o3 = Observable.just("3");

7calore

2risposta

RxJ: Come eseguire il ciclo in base allo stato dell'osservabile?

Sto cercando di far sì che gli RxJ passino su un Observable nel mio stream finché non si trova in un determinato stato, quindi il flusso continua. Nello specifico sto convertendo un loop do/while sinc

8calore

2risposta

Qual è il modo corretto di gestire la transazione nei servizi RxJava?

Di recente ho iniziato a sperimentare con RxJava e sono imbattuto in una presentazione da parte di un ingegnere di Netflix che ha suggerito lo spostamento nostre API di business per le API osservabile

6calore

2risposta

RxJS: Come avere un osservatore per elaborare più oggetti osservabili?

Sto lavorando con un framework che chiama una funzione che implemento. Vorrei che il parametro di questa funzione fosse convertito in Osservabile e inviato attraverso una sequenza di Osservatori. Pens

13calore

1risposta

Inspiegabile mancanza di miglioramento delle prestazioni utilizzando RxJava Observables in applicazioni Web

Sto eseguendo alcuni test per valutare se c'è un reale vantaggio nell'utilizzo di API reattive basate su Observables, invece dei tradizionali di blocco. Tutta esempio è available on Githug Sorprendent

5calore

1risposta

Qual è la differenza tra Reattivi e Reattivi?

Sto cercando di capire la differenza tra Reactive e ReactiveStreams, in particolare nel contesto di RxJava? Il massimo che ho potuto immaginare è che Reactive Stream ha qualche nozione di contropressi

7calore

2risposta

Angular 2.0 - conversione del concatenamento di promesse agli oggetti osservabili

Sto convertendo un servizio NG 1.X in NG 2.0. mio NG servizio 1.X ha promessa concatenamento (semplificato): dataService.search = function(searchExp) { return this.getAccessToken() .then(f

6calore

2risposta

Riduzione RxJS non continua

Perché il flatMap non causa il rischio di riduzioni a valle? ho ottenuto il codice come: handleFiles.flatMap(files => Rx.Observable.from(files). flatMap((file, i) => fileReader(file, i)).

19calore

1risposta

Confronto di Java quadri reattivi

Vedo molti framework/librerie che sostengono che essi possono aiutare a costruire applicazioni reattive in Java, come ad esempio: Akka, Vert.x, RxJava, Reattore, Qbit, ecc Sembrano hanno approcci, car

8calore

2risposta

Come richiedere i dati sequenzialmente in Cycle.js?

Sono nuovo alla programmazione reattiva e gironzolo con cycle.js, cercando di implementare chi seguire la casella da this tutorial. Ma ho capito che per una corretta implementazione (e scopi di appren