Convertir un flux de promesses en un flot de valeurs

Question

Je suis un peu nouveau chez RxJs et j'essaie de mélanger le monde des promesses et des observables.

Voici ce que je veux: J'ai une observable (appeler clickObs) qui écoute un clic et à la suite interroge une base de données, la production d'une promesse qui résout à une valeur lorsque l'interrogation de base de données se termine (avec succès). Mon observable génère ainsi un flux de promesses à partir d'un flux de clics, et ce que je veux c'est générer à partir de cet observable, un flux de valeurs résolues correspondantes.

Des questions passées sur StackOverflow, j'ai lu defer, flatMap, mergeAll et fromPromise, mais ne peut pas obtenir ma tête autour de la façon d'articuler les quatre pour résoudre mon problème.

Des suggestions?

Answer 1

Vous ne devriez pas avoir tous les quatre, il suffit de regarder à flatMap ou ses frères et soeurs flatMapLatest

clickObs.flatMapLatest(function() { 
    //Access the db and return a promis 
    return database.query(queryObj); 
}) 
.subscribe(function(result) { 
    //Result is implicitly flattened out 
    /*Do something with the result*/ 
}); 

flatMap convertira implicitement une promesse ou d'un objet semblable à un tableau dans un Observable et aplatir la séquence résultante. FlatMapLatest est similaire mais ignore les anciens événements, si un nouveau arrive avant que le précédent ne soit terminé.