reactive-programming

7calore

3risposta

Come ascoltare la fine di un'animazione css con Angular2 e Reactive

Desidero eseguire manualmente le transizioni di pagina nella mia app Angular2. Quindi quello che ho fatto finora è prodotto da un servizio che chiamo da una Componente che si occupa della navigazione.

6calore

2risposta

Emetti il prossimo valore dalla sorgente Osservabile quando un altro osservabile, il notificatore, emette

Mi aspetterei che il mio caso sia comune ma non riesco a trovare nulla di appropriato. Quello che voglio raggiungere, in Angular2/RxJS 5 è questo: source: ---1--2--3--4---------5--------6-|--> notifi

7calore

1risposta

Angular2: Come importare rx-dom

voglio usare DOM nel progetto angolare come questo Rx.DOM.jsonpRequest ma DOM non è disponibile sul Rx che Im importazione come questo import Rx = require('rxjs'); Ho anche provato importare rxjs

28calore

1risposta

Chaining osservabili in RxJS

sto imparando RxJS e angolare 2. Diciamo che ho una catena di promessa con più chiamate di funzione asincrona che dipendono dalla precedente uno dei risultati che si presenta come: var promiseChain =

8calore

1risposta

Come unire due stream di eventi su una proprietà evento comune?

Considerare i seguenti due flussi di eventi. Ogni evento ha un timestamp/ts e una proprietà value. voglio combinare questi due flussi in cui gli eventi hanno gli stessi timestamp, in un flusso risulta

16calore

6risposta

errore di cattura se retryWhen: s tentativi esaurisce

Nel documentation for RetryWhen l'esempio c'è questa: Observable.create((Subscriber<? super String> s) -> { System.out.println("subscribing"); s.onError(new RuntimeException("always fails"))

6calore

2risposta

Come gestire l'errore di rete in React-Native, quando la rete è spenta

Come gestire l'errore di rete in React-Native, quando il dispositivo non è connesso alla rete. Il mio scenario sta cercando di connettere qualche api, mentre il recupero della richiesta se la rete è d

6calore

2risposta

RxJava - Di fronte all'operatore switchMap()?

Mi chiedo se esiste un modo per comporre gli operatori esistenti per eseguire l'opposto di switchMap(). Il switchMap() insegue l'ultima emissione ricevuta e annulla qualsiasi Observable precedentement

7calore

2risposta

RxJS distinctUntilChanged - compendio oggetto

Ho flusso di oggetti e ho bisogno di confrontare se l'oggetto corrente non è uguale al precedente e in questo caso emettere un nuovo valore. Ho trovato che l'operatore distinctUntilChanged dovrebbe fa

8calore

2risposta

Come rendere un cursore circolare in nativo reattivo

Desidero aggiungere un componente dell'intervallo simile. Ma uno che è in realtà circolare e non ho idea di come farlo. Puoi indicarmi un aiuto per favore. Te esempio di quello che voglio: