如何完成combineLatest？

Question

我使用 combineLatest 从每个可观察值中获取最新值：

combineLatest$ = combineLatest(_block$, _field$);
    combineLatest$.subscribe(() => {
      console.log("Completed...");
    });

然后我有另一个 observable 在 forkJoin$ 发送数据之前一直有效：

of(true).pipe(delay(1000), takeUntil(combineLatest$)).subscribe(() => console.log());

如何完成combineLatest$？我应该取消订阅 of() 还是它会自动销毁？

Answer 1

没有。 takeUntil 将为您运行拆解逻辑。您似乎混淆了 forkJoin 语义和 combileLatest，它们是完全不同的。在您的特定情况下 forkJoin$ 没有 true forkJoin semantics；我想您必须完成 _block$ 和 _field$ 才能完成 combineLatest。

如何完成combineLatest？

How to complete combineLatest?

rxjs

rxjs6

rxjs-observables