Angular 2 - Run 2 Abonnement in der gleichen Zeit

Question

Ich habe den folgenden Code:

//Subscription 3: role ID to role Name 
     af.database.object('/roles/'+businessRole.$value) 
     .subscribe((roleData) => { 
     //Subscription 4: Get user info 
     af.database.object('/users/'+businessRole.$key).subscribe(user => { 

der ein Abonnement in einem Abonnement enthält.

Das Problem hier ist, dass die App auf die erste wartet, bevor die zweite läuft. Ich möchte beide auf einmal ausführen und das Ergebnis von jedem erhalten. Wie kann ich das machen?

Ich habe mit Promise.All() vor, aber:

1. Ich würde gerne wissen, wie ich kann mit rxjs
tut
2. ich nicht einen Weg finden könnte das Ergebnis jeder beobachtbaren mit Promise.All() zu erhalten

Dank

Answer 1

Dies schafft zwei Observables, die nach 1000ms und 900ms abgeschlossen sind. Wenn Sie diese Demo ausführen, sehen Sie, dass die erste nur einen Moment nach der ersten abgeschlossen ist, um zu beweisen, dass diese parallel ausgeführt werden.

let obs1 = Observable.of('HTTP Response 1').delay(1000); 
let obs2 = Observable.of('HTTP Response 2').delay(900); 

console.log('Start'); 

obs1.merge(obs2) 
    .subscribe(val => console.log(val), undefined,() => console.log('Completed')); 

Siehe Live-Demo: http://plnkr.co/edit/hzmpclxDkIhnfTYcWXd5?p=preview

Diese Drucke zu trösten:

Start 
HTTP Response 2 
HTTP Response 1 
Completed 

Wenn Sie forkJoin() benötigen, dann Observable.forkJoin() doesn't executes meine vorherige Antwort sehen :).

Answer 2

ich glaube Observable.forkJoin ist genau das, was Sie in Ihrer Situation zu verwenden müssen. Diese

ist, wie Sie Ihren Code wie mit forkJoin aussehen:

Observable.forkJoin(
this.http.get('/roles/'+businessRole.$value).map((response: Response) => res.json()), 
this.http.get('/users/'+businessRole.$key).map((response: Response) => res.json()) 
).subscribe(data => { 
    data[0] // this will contain roleData 
    data[1] // this will contain user 
}, 
error => console.log(error)); 

This eine nützliche Verbindung ist, wo Sie mehr über Observablen lernen können und wie forkJoin zu verwenden.