角度 rxjs 间隔未订阅

Question

我有这段代码：

interval(180000).pipe(takeUntil(this._unsub$)).subscribe(() => myFunc())

_unsub$ 是在 ngOnDestroy 方法中触发的主题。 我的问题是 myFunc 永远不会被执行。

另一个组件中的同一段代码可以工作。我不明白为什么。

timer(0, 180000).pipe(takeUntil(this._unsub$)).subscribe(() => myFunc())

有效。 我对计时器的问题是，即使我调用，有时也会调用该函数

ngOnDestroy() {
   this._unsub$.next();
   this._unsub$.complete();
}

你猜为什么会这样？

Answer 1

interval 和 timer 都是冷的 observables，并且 observables 是惰性的（与 promises 不同），因此在您订阅之前不会调用您的计时器，并且在您订阅时会创建一个新的计时器。

这两个设置是一样的：

const firstFunc = () => ...
const secondFunc = () => ...
const interval1$ = interval(180000).pipe(takeUntil(this._unsub$));
const interval2$ = interval(180000).pipe(takeUntil(this._unsub$));
interval1$.subscribe(firstFunc);
interval2$.subscribe(secondFunc);

const firstFunc = () => ...
const secondFunc = () => ...
const interval$ = interval(180000).pipe(takeUntil(this._unsub$));
interval$.subscribe(firstFunc);
interval$.subscribe(secondFunc);

所以你必须考虑何时调用.subscribe。这是我解释不同组件中非常相似的代码之间差异的最佳猜测。如果在订阅定时器之前调用了this._unsub$.next();，那么在 180 秒后，定时器仍然会触发，因为它从未收到 _unsub$ 信号。