Comment combiner l'abonnement Rx.js avec Jquery Promise?

Question

J'utilise Rx.js et JqueryPromises J'ai rencontré une situation où j'appelle une méthode pour traiter un événement publié par Rx. Cette méthode renvoie cependant une promesse.

eventStream.Subscribe(function(e) { methodThatReturnsPromise(e);}); 

Le problème est que le traitement des événements n'est plus déterministe. Comme méthodeThatReturnsPromise renvoie immédiatement car il diffère le traitement.

Ma question :) Existe-t-il un moyen d '«attendre» une promesse? Existe-t-il des points d'ancrage permettant à Rx d'utiliser les promesses, c'est-à-dire d'enchaîner la promesse retournée d'un abonnement avec la prochaine promesse d'abonnement retournée, de sorte que les messages sont toujours traités dans l'ordre?

Answer 1

Ce code semble faire l'affaire pour toute personne intéressée. J'ai juste besoin d'enchaîner les retours différés.

Fiddle here

var seed = $.Deferred(); 
seed.resolve(); 
observable.aggregate(seed, function(chain, n){ 
    return chain.then(function(){ 
     console.log("Starting on Event " + n); 
     return process(n); 
    }); 
}).subscribe();