每一个都会发出几次

Question

我尝试了以下使用 ngrx 作为源可观察的代码。

this.continue$ = this.store.select(s => s.cart)
  .switchMap( cart => Observable.from(cart.items) )
  .every( item => item.amount > 0 && item.amount <= item.max_amount )

我试图做的是，每次发出新Cart时，测试该Cart中的所有项目，如果每个项目都通过某个条件，则发出一个布尔值。

我尝试使用 every() 操作，但现在我明白every()永远不会发出一些东西，因为源可观察量永远不会完成。（如果它完成，every()只会发出一次，因为这就是它的工作原理）

我的问题是，有没有办法解决我的问题，比（不需要subscribe）更好

this.store.select(s => s.cart)
  .subscribe( cart => {
    this.continue$ = Observable.from(cart.items)
      .every( item => item.amount > 0 && item.amount <= item.max_amount )
  });

Answer 1

我认为这可以完成这项工作。注意，这使用 Array.every() ，我假设cart.items是一个数组。

this.continue$ = this.store.select(s => s.cart)
  .map( cart => 
    cart.items.every(item =>
      item.amount > 0 && item.amount <= item.max_amount 
    )
  );

---

实际上，您可能会发现这有效

this.continue$ = this.store.select(s => 
  s.cart.items.every(item =>
   item.amount > 0 && item.amount <= item.max_amount 
  )
);