rxjs forkjoin erfüllt nicht

Question

Ich habe zwei Rxjs Observables basierend auf asynchronen FileReader-Operationen. Die Abonnements auf jedem von ihnen abgeschlossen einzeln, aber mein Versuch, forkJoin sie führt nie seine .subscribe Methode. Klar habe ich es falsch eingerichtet; her der Code:

let observe1 = this.Service1.parsedResponse$; 
let observe2 = this.Service2.parsedResponse$; 

observe1.subscribe((data) => { 
    console.log('subscription 1', data); // this executes 
}); 

observe2.subscribe((data) => { 
    console.log('subscription 2', data); // this executes 
}); 

let observeJoined = Observable.forkJoin(observe1, observe2); 

observeJoined.subscribe((data: Object[]) => { 
    console.log('are we forkjoined?', data); // never happens 
}); 

Was ich suche im Idealfall nur zwei Objekte (data1, Daten2); Sie müssen nicht zu einem Ergebnis kombiniert werden. Ich muss nur wissen, dass ich beide habe, bevor ich fortfahre. Vielen Dank!

Answer 1

Versuchen Sie folgendes:

var source = Rx.Observable.forkJoin(
this.Service1.parsedResponse$, 
this.Service2.parsedResponse$ 
); 

var subscription = source.subscribe(
    function (x) { 
    console.log('Next: %s', x); 
    }, 
    function (err) { 
    console.log('Error: %s', err); 
    }, 
    function() { 
    console.log('Completed'); 
    });