使用 Rx 放入篮子/从篮子中取出

Question

我有两个数据流：

1. 布尔流，指示商品是否存在于购物篮中。
2. 点击流，它启动了将项目放入/删除到购物篮/从购物篮中删除。

首先，我想根据布尔流更改切换按钮的标题。这很简单。其次，我想将布尔流中的最新值和 Clicks 流中的事件结合起来，以发起放置或删除请求。

这是我迄今为止尝试过的：

// handling the toggle button caption
inBasketStream.subscribe(inBasket -> {
    mPurchaseButton.setText(inBasket ? "Already in basket" : "Purchase");
});

// handling clicks and deciding whether to add or remove item
Observable.combineLatest(
        inBasketStream,
        ViewObservable.clicks(mPurchaseButton),
        (inBasket, onClickEvent) -> inBasket).subscribe(inBasket -> {
            if (inBasket) {
                mRemoveFromBasket.call(mItemId);
            } else {
                mAddInBasket.call(mItemId);
            }
        }
);

但是，combineLatest 不能胜任我的工作。相反，它会导致递归，因为至少发生了一次点击事件，并且 inBasketStream 在操作完成时更新。 Zip 也无济于事，因为在篮子流中可能会从另一个地方更改，因此存在堆叠多个布尔值的场景，这将使 zip 过时（只是下一个，而可能已经有更多值了堆叠在）下一次点击事件的值。

所以，我需要一种方法来从布尔流中获取 最后一个 值，并在点击事件发生时使用它。当然，我可以为此使用一个布尔字段（订阅 inBasketStream 并更新它 onNext），但我认为它不符合功能性，并且必须有一个组合来处理这个问题而无需额外的字段/变量。

谢谢。

附：两个 observables 都很热

Answer 1

看看withLatestFrom。它只会在主源发出同时结合其他源的最新值时传播。

ViewObservable.clicks(mPurchaseButton)
              .withLatestFrom(inBasketStream, 
                             (dontCare, inBasket) -> inBasket)
.subscribe(/*do your update*/);