Wie kann ich mich von einem Observable, das von forkJoin zurückgegeben wurde, abmelden?

Question

In meiner App Angular2-typescript verwende ich forkJoin, um ein Observable erst zurückzuschicken, wenn alle parallelen HTTP-Aufrufe durchgeführt wurden.

Ausgabe: das Abonnement Rückruf Hier unbegrenzt

ausgeführt wird, hält mein Code:

http.service

import {Http} from "@angular/http"; 

constructor (private _http: HTTP) {} 

makeGetRequest(....) { 
    return this._http.get(URL) 
      .map (res => res.json) 
      .toPromise(); 

my.service

import {Observable} from "rxjs/Observable"; 
import {HttpService} from "http.service" 

constructor (private _httpService: HttpService) {} 

myMethod(): Observable<any[]> { 
return Observable.forkJoin(
      this._httpService.makeGetRequest(
       URL1 
      ), 
      this._httpService.makeGetRequest(
       URL2 
      ) 
     ) 
} 

my.component

import MyService from "my.service"; 
import Subscription from "rxjs"; 

constructor (private _service: MyService) {} 

mySub: Subscription; 

ngOnInit() { 
    this.mySub = this._service.myMethod.subscribe(data => { 
     data.forEach(console.log(data)); 
     this.mySub.unsubscribe(); 
    } 
} 

Was ich (gleiche Ausgabe) versucht:

• Rückkehr eine beobachtbare in Http.service eher als ein Versprechen
• in my.component Verwendung .First() .subscribe() statt nur subscribe()
• put this.mySub.unsubscribe(); am Ende des ngOnInit anstatt innerhalb der Callback-subscribe (auch mit setTimeout (() => ....))

Answer 1

Wie forkJoin reference sagt, es

Läuft alle beobachtbaren Sequenzen parallel und sammle ihre letzten Elemente.

Dies bedeutet, dass der Operator Werte von abgeschlossenen Observablen erhält und eine vollständige Observable mit einem einzelnen Wert zurückgibt. Sie müssen sich nicht abmelden.