RXJS:计算组件中的可观测阵列长度

订阅中包含的内容不会影响可观察到的源,因此,如果要取消订阅,则需要使用完成链或手动取消订阅的运算符。

例如,如果您知道要接受多少项,则可以使用 take(N) 或者如果它取决于某种条件,你可以使用 takeWhile() . 或者你可以用 scan() 把它和 () 例如。

您还可以在订阅呼叫中取消订阅:

this.purchases$.subscribe(function(val) {
  if (condition) {
    this.unsubscribe();
  }
});

注意,在这种情况下,不能使用箭头函数 () => ... 因为RXJS绑定 this 当前上下文 Subscription 对象。所以你可以打电话 this.unsubscribe() 取消订阅(这不是一个黑客,它的目的是这样使用)。

我建议您使用 first operator 要使第一个结果发出后自动完成的可观测数据:

this.purchases$.pipe(first()).subscribe((val) => {
  val.length > 0 ? this.purchaseType = 'initial' : this.purchaseType = 'additiona';
})