angular - 无法让 forkJoin 开火

Question

我正在 Angular 中构建一个守卫，我需要在其中发出两个不同的 HTTP 请求，并根据这两个请求来确定是否继续。我注意到 forkJoin 是执行此操作的正确方法，但我无法触发。

在我的代码中，我有:

this.userService.watchCurrentUser().subscribe(data => { console.log(data) });
this.orgService.watchOrg().subscribe(data => { console.log(data) });
Observable.forkJoin(
    this.userService.watchCurrentUser(),
    this.orgService.watchOrg()
).subscribe(data => {
    console.log(data);
});

前两个订阅是后来添加的，以测试调用是否真的触发了，它们确实触发了；我看到了他们的日志。但我从未从 forkJoin 中看到很多东西。

我在我的文件顶部导入它:

import { Observable, BehaviorSubject } from 'rxjs/Rx';
import 'rxjs/add/observable/forkJoin';

为了使用 forkJoin，我还缺少其他东西吗？

Answer 1

Observable.forkJoin() 要求所有源 Observable 至少发出一项并完成。

您确定您的两个源 Observable 都已完成吗？

如果他们不这样做(并且基于他们的内部逻辑他们不能)，也许您更愿意使用 zip() 或 combineLatest()。