観測可能なforkJoinが発射しない

Question

私はユーザOboevableにforkJoinを預けてみようとしています。そのうちの1つはストリームとして開始されます...私が直接それらに購読すれば、私は応答を受け取りますが、forkJoinは発砲していません。何か案は？

private data$: Observable<any[]>; 
private statuses$: Observable<any[]>; 
private queryStream = new Subject<string>();  

.... 

this.data$ = this.queryStream 
    .startWith('') 
    .flatMap(queryInput => { 
      this.query = queryInput 
      return this._companyService.getCompanies(this.queryRequired + ' ' + this.query, this.page, this.sort); 
       }) 
      .share(); 

... 

Observable.forkJoin(this.statuses$, this.companies$) 
      .subscribe(res => { 
       console.log('forkjoin'); 
       this._countStatus(res[0], res[1]); 
      }); 


// This shows arrays in the console... 

this.statuses$.subscribe(res => console.log(res)); 
this.companies$.subscribe(res => console.log(res)); 

// In the console 
Array[9] 
Array[6] 

Answer 1

forkJoinと非常に一般的な問題は、それが完了する必要があり、少なくとも一つの項目とそれらのすべてを放出するために、すべてのソースの観測を必要とすることです。

つまり、this.statuses$またはthis.companies$がアイテムを放出しない場合、両方が完了するまで、forkJoinは何も放出しません。

this.statuses$.subscribe(
    res => console.log(res), 
    undefined, 
    () => console.log('completed'), 
); 

Answer 2

Observable.forkJoin([ 
     _someService.getUsers(), 
     _someService.getCustomers(), 
    ]) 
     .subscribe((data: [Array<User>, Array<Customer>]) => { 
     let users: Array<User> = data[0]; 
     let customer: Array<Customer> = data[1]; 
     }, err => { 
     }); 





     //someService 
     getUsers():Observable<User> { 
      let url = '/users'; 
      return this._http.get(url, headers) 
      .map(res => res.json()); 
     } 

     getCustomers():Observable<Customer> { 
      let url = '/customers'; 
      return this._http.get(url, headers) 
      .map(res => res.json()); 
     }