Làm thế nào để hủy đăng ký khỏi một Observable được trả về bởi forkJoin?

Question

Trong ứng dụng Angular2-typescript của tôi, tôi đang sử dụng forkJoin để trả về một Observable chỉ khi tất cả các cuộc gọi HTTP song song được thực hiện.

Issue: gọi lại thuê bao tiếp tục được thực hiện vô thời hạn

Đây là mã của tôi:

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(); 
    } 
} 

gì tôi đã cố gắng (cùng một vấn đề):

• trở lại một quan sát ở Http.service chứ không phải là một lời hứa
• sử dụng my.component .first() .subscribe() thay vì chỉ đăng ký()
• đặt this.mySub.unsubscribe(); ở phần cuối của ngOnInit chứ không phải bên trong đăng ký callback (cũng với setTimeout (() => ....))

Answer 1

Như forkJoin reference nói, nó

Chạy tất cả các chuỗi quan sát song song và thu thập các yếu tố cuối cùng của họ.

Điều này có nghĩa là toán tử nhận giá trị từ các quan sát đã hoàn thành và trả về một giá trị được hoàn thành có thể quan sát được với một giá trị duy nhất. Không cần phải hủy đăng ký khỏi nó.