Observable.forkJoin无法正常工作

Question

我实例化了两个Observable对象：

const observable1 = new Observable.create(observer => observer.next(1)); 
const observable2 = new Observable.create(observer => observer.next(2));  
Observable.forkJoin([observable1, observable2]).subscribe(res => console.log(res));

forkJoin()即使每个observable.subscribe（）都在工作，以上内容也不起作用。

有什么想法吗？

谢谢

Answer 1

forkJoin在发出结果值之前，等待所有输入流完成。由于您没有完成可观察性，因此它永远不会发出任何东西。另外，您不需要new，Observable.create可以forkJoin直接导入-无需在上使用它Observable。将您的实现更改为此：

import { forkJoin } from 'rxjs/observable/forkJoin';
import { Observable } from 'rxjs/Observable';

const observable1 = Observable.create(observer => { observer.next(1); observer.complete() });
const observable2 = Observable.create(observer => { observer.next(2); observer.complete() });

forkJoin([observable1, observable2]).subscribe(res => console.log(res));

有关组合运算符的一个很好的解释，包括forkJoin：

• 学习将RxJs序列与超直观的交互图结合起来