2017-12-19 18 views
0

このforkJoinは、その中のオブザーバブルが行っても完了しません。何が欠けていますか?rxjs forkJoinは決して完了しません

return Observable.forkJoin([ 
    this.ProductManager.get(params['brandId'], params['productId']) 
    .map(product => <Product> product) 
    .do(product => {this.product = product;}) 
    .do(() => console.log('a1'),() => console.log('a2'),() => console.log('a3')), 

    this.basketContext.basket.take(1) 
    .do(() => console.log('b1'),() => console.log('b2'),() => console.log('b3')) 
]) 
.do(() => console.log('1'),() => console.log('2'),() => console.log('3')); 

コンソール:

b1 
b3 
a1 
a3 
1 

はなぜforkJoinためonCompleteのは、呼び出されることはありませんか?

+0

すべてのソースオブザーバブルが少なくとも1つのアイテムを放出していますか? – martin

答えて

0

次のsubscribe()がエラーをスローすると、完全なコールバックは決して終了しませんでした。エラーはサイレントなので、forkJoinが完了していないと誤解しました。

関連する問題