如何在可观察的反应式扩展中记住以前的有效负载？

Question

我有一个 IObservable boolObservable，发布者的行为就像 switch。还有带有一些值的变量 currentItem 和包含预定义不可变值的 defaultItem。每当发布 'true' 时，应记住 currentItem 的值，并且应将 currentItem 设置为 defaultItem。发布“false”时，currentItem 的值应更改为之前的值。 实现这一点的最简单方法是使用局部变量。

IObservable<bool> boolObservable;
string currentItem;
string defaultItem;

string local = null;
boolObservable.Subscribe(x =>
  {
    if (x) {
      local = currentItem;
      currentItem = defaultItem;
    }
    else
      currentItem = local;
  });

当我必须多次重复此操作并且每次都以不同的方式命名用于存储的局部变量时，问题就开始了。有没有办法使用 Rx 操作符来“记住”不仅是最新的有效载荷，而且是之前的有效载荷？

UPD：@ibebbs 下面的回答绝对正确，Scan 运算符提供了必要的行为：

var switchSource = new BehaviorSubject<bool>(false);
string currentItem = "FromDb";
string defaultItem = "Default";

switchSource
    .Skip(1)
    .Scan(string.Empty, (local, b) =>
    {
        if (b)
        {
            local = currentItem;
            currentItem = defaultItem;
        }
        else
            currentItem = local;

        return local;
    })
    .Subscribe();

Console.WriteLine($"Initial value: {currentItem}"); // FromDb
switchSource.OnNext(true);
Console.WriteLine($"Default value: {currentItem}"); // Default
switchSource.OnNext(false);
Console.WriteLine($"Initial value again: {currentItem}"); // FromDb
currentItem = "UserChanged";
Console.WriteLine($"UserChanged value: {currentItem}"); // UserChanged
switchSource.OnNext(true);
Console.WriteLine($"Default value: {currentItem}"); // Default
switchSource.OnNext(false);
Console.WriteLine($"UserChanged value again: {currentItem}"); // UserChanged

Answer 1

您可以使用Scan 通过可观察序列来线程化状态。例如：

public static IObservable<string> EitherItemOrDefault(IObservable<bool> switchSource, IObservable<string> itemSource, string defaultValue)
{
    return switchSource
        .WithLatestFrom(itemSource.StartWith(string.Empty), (switchValue, itemValue) => (Switch: switchValue, Item: itemValue))
        .Scan(
            (Current: string.Empty, Local: string.Empty),
            (seed, tuple) => tuple.Switch 
                            ? (Current: defaultValue, Local: tuple.Item) 
                            : (Current: seed.Local, Local: seed.Local))
        .Select(tuple => tuple.Current);
}

这将IObservable<bool> 作为您的“开关”，将IObservable<string> 作为项目（在您的示例中为currentItem）并返回一个IObservable<string>，当switchSource 发出一个@ 时，它将包含defaultValue 987654329@ 和最后一个 currentItem 值，当 switchSource 发出 True 时。

注意：我可能有 current 和 local 倒退。已经很晚了，您的示例巧妙地说明了为什么应该避免全局状态......这很难推理。