reactive-programming

7calore

1risposta

RxJS: divisione di un risultato di matrice da Observable.fromPromise

Sto utilizzando RxJS qui e non riesco a superare questo problema semplice apparentemente. rx.Observable .from([1,2,3,54,3,22,323,23,11,2]) .distinct() .subscribe(function next (x) {

71calore

2risposta

RxJS: Come posso aggiornare "manualmente" un Osservabile?

Penso che dovrei fraintendere qualcosa di fondamentale, perché nella mia mente questo dovrebbe essere il caso più fondamentale per un osservabile, ma per la vita del mio non riesco a capire come farlo

6calore

3risposta

Combinazione di due osservabili <Void> s

Sono ancora un principiante reattivo e sto cercando aiuto. func doA() -> Observable<Void> func doB() -> Observable<Void> enum Result { case Success case BFailed } func doIt() -> Observ

5calore

1risposta

Perché le operazioni osservabili vengono chiamate una volta (duplicate) per ogni utente?

Ogni volta che si chiama .subscribe() su un Observable, l'elaborazione su ciascun valore viene riavviata (nell'esempio seguente, la funzione mappa verrà chiamata due volte per ciascun valore). var rx

8calore

4risposta

Rx - flusso Divide in segmenti (liste) di condizione

Ho un produttore RX che crea un flusso di stringhe in questo modo (versione semplificata del reale flusso): A1 A2 A3 B1 B2 C1 C2 C3 C4 C5 C6.... il flusso è senza fine, ma ordinato. Quindi, dopo che l

5calore

2risposta

Imposta il valore di un elemento HTML selezionato in modo reattivo con Meteor

Desidero impostare il valore di un elemento HTML <select> in modo reattivo, senza modificare le varie opzioni per l'elemento. Ho trovato una soluzione, ma non elegante. Per provare, creare una meteora

7calore

1risposta

Il thread di annullamento della sottoscrizione è sicuro in RxJava?

Supponiamo che io ho il seguente codice RxJava (che accede a un DB, ma il caso esatto uso è irrilevante): public Observable<List<DbPlaceDto>> getPlaceByStringId(final List<String> stringIds) { re

6calore

1risposta

Come posso prendere il controllo di canEditRowAtIndexPath quando si utilizza l'estensione RxCocoa per UITableView

Solo per il record prima di lanciarmi nella mia domanda sto usando Swift 2 e xcode 7 beta. Quindi sto usando RxSwift e RxCocoa per associare il mio ViewModel al TableView. Nel mio UITableViewControlle

5calore

1risposta

RxJS combineLatest: come ottenere l'emissione dopo aver modificato un solo valore?

Sto cercando di imparare la libreria RxJS. Uno dei casi che non capisco è descritto in this jsfiddle (codice anche sotto). var A= new Rx.Subject(); var B= new Rx.Subject(); A.onNext(0); // '.com

9calore

2risposta

esecuzione con Rx

ho il seguente flusso lettera singola A B C A D B A C D E da questo flusso, vorrei un flusso di conteggio parziale per lettera (A,1) (A,1), (B,1) (A,1), (B,1), (C,1) (A,2), (B,1), (C,1)