javascript - RXJS:如何使用 takeUntil 直到另一个 Observable 完成(并且不发出)

Question

我有两个 Observable:

1:累加一个值完成。 (重要:可能在发出任何值之前完成!)

2: 做事直到 1 完成(不发出)

你会如何在 RxJS 中实现它？

我的第一个尝试是像这样使用 last():

firstObservable.pipe(
    takeUntil(secondObservable.pipe(last()))
  ).subscribe(count =>{
    //do stuff with count
  });

但是当 firstObservable 完成而没有发出任何值时，问题就出现了。出现错误:

Error: no elements in sequence

问题:我如何使用 takeUntil(或任何其他运算符)在 observable 2 完成后停止订阅，并且在没有发出最后一个值时不抛出错误？

Answer 1

您可以在 secondOvservable 上使用 finalize 并在那里完成 firstObservable。这样它不依赖于发出的任何值，只依赖于完整的事件。

secondOvservable.pipe(
  finalize(() => firstObservable.complete())
).subscribe(count =>{
  //do stuff with count
});