Abonnieren innerhalb eines mehrfach Abonnieren wiederholende

Question

Ich habe eine beobachtbare, der auf ein Array ausgibt

subscribe

appleProducts.subscribe((snap) => { 
    console.log(snap); 
}); 

iphone.subscribe((snap) => { 
    console.log(snap); 
}); 

Konsolausgabe:

[ipad, iphone, Mac]

[ iphone4, iphone5, iphone6]

---

Die beiden Abonnenten werden asynchron ausgeführt. Ich brauche aber appleProducts vor iphone zu bekommen, also wenn ich setze iphone.subscribe Funktion innerhalb appleProducts.subscribe Funktion, etwas sonderbaren passiert:

appleProducts.subscribe((snap) => { 
    console.log(snap); 
    iphone.subscribe((snap) => { 
     console.log(snap); 
    }); 
}); 

Konsolenausgabe:

[ipad, iphone, mac]

[iphone4]

[iphone4, iphone5]

[iphone4, iphone5, iphone6]

---

Versteht jemand, warum dies geschieht? Dank

Answer 1

Verwenden Sie AngularFire2? Wenn ja, dann hängt dies mit dem Problem der Firebase-Liste zusammen. sie daran zu arbeiten

sehen diese https://github.com/angular/angularfire2/issues/574

Answer 2

Um die Ergebnisse von einer beobachtbaren alle, bevor die Ergebnisse aus dem nächsten, die instance operator concat

appleProducts.concat(iphone).subscribe(...) 

Das Abonnement wird zunächst gibt die Ergebnisse des ersten beobachtbaren verwenden. Sobald dies abgeschlossen ist, werden die Ergebnisse des zweiten ausgegeben.

Sie könnten das gleiche Ergebnis unter Verwendung des static method concat

Observable.concat(appleProducts, iPhone).subscribe(...) 

Answer 3

So, nachdem führen zum ‚concat‘ Funktion von rxjs ist, schaute ich in andere Dinge wie ‚forkJoin‘ (was nicht funktioniert) gefunden, und ich meine Lösung mit 'merge'

Lösung von Beispielcode:

var source = Rx.Observable.merge(
    appleProducts, 
    iphone); 

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

Konsole Ausgang:

[ipad, iphone, mac]

[iphone4, iphone5, iphone6]