Wie kombiniere ich Intervall-Stream mit Promise-Stream in RxJs und bekomme die Werte?

Question

Ich lerne RxJs und es ist ziemlich cool. Ich versuche eine Seite zu erstellen, auf der der Ajax-Aufruf ein Intervall ist, so dass die Daten alle 5 Sekunden aktualisiert werden. Also dachte ich, ich würde das machen.

var ajax = new Promise(function(resolve) { 
    return resolve('test'); 
}); 

var source1 = Rx.Observable.interval(5000) 
    .map(function(i) { 
    return Rx.Observable.fromPromise(ajax); 
    }); 

source1.subscribe(function(res) { 
    res.subscribe(function(pro) { 
    console.log(pro); 
    }) 
}); 

jedoch die Tatsache, dass ich tun muss zwei subscribe s hat mir denken, dass ich vielleicht falsch hier etwas tun. Ich bin mir nicht sicher, ob ich in die richtige Richtung gehe?

Was ich will, ist ein Strom von Versprechen, die alle 5 Sekunden abgerufen werden.

Hier ist meine jsfiddle

https://jsfiddle.net/noppanit/2y179dgg/

Answer 1

Sie müssen flatMap Operator verwenden. Werfen Sie einen Blick auf die jsbin here.

var ajax = new Promise(function(resolve) { 
    return resolve('test'); 
}); 

var source1 = Rx.Observable.interval(1000) 
    .flatMap(function(i) { 
    return Rx.Observable.fromPromise(ajax); 
    }); 

source1.subscribe(function(res) { 
    console.log(res); 
}); 

Es gibt umfangreiche Beispiele für die Verwendung von flatMap auf SO verfügbar.

Sie können auch konsultieren:

• Von SO: Why we need to use flatMap?
• die schön präsentiert: The introduction to Reactive Programming you've been missing
• Amts doc: https://github.com/Reactive-Extensions/RxJS/blob/master/doc/api/core/operators/selectmany.md
• Illustrative Marmor: http://reactivex.io/documentation/operators/flatmap.html