c# - 有没有办法为响应式(Reactive)扩展可观察对象指定初始值？

Question

在 reactiveui 和 reactive extensions 中，您可以将多个 observables 合并为一个。使用诸如 CombineLatest 或 Zip 之类的函数，您可以使生成的可观察对象使用一个函数来根据组合可观察对象的值计算结果。尽管 CombineLatest 为您提供了一个可观察对象，它会在每次任何组合的可观察对象触发时向您发出通知，但只有当所有这些可观察对象至少触发一次时，它才会开始工作。我希望它从一开始就发出通知——给组合的可观察值一个初始值，或者其他东西。当然，我可以以某种方式让那些可观察到的火来设置初始值。但有时并不是那么容易，或者会让代码看起来很难看。这是一个例子:我正在使用 reactui 制作一个 wpf 应用程序。在我的一个 View 模型中，我试图通过组合可观察对象来创建属性。因此，我有一个具有 NumberToSum 属性的对象集合 (ReactiveList)，我需要一个用于显示该属性值总和的属性。该集合中的对象也是 View 模型，它们的 NumberToSum 属性可以由用户更改。求和的对象数量由其他属性决定。这就是我尝试这样做的方式:

private readonly ReactiveList<Element> _collection = new ReactiveList<Element>();
private readonly ObservableAsPropertyHelper<int> _sum;
private int _elementsToTake = 0;

public int ElementsToTake
{
    get { return _elementsToTake; }
    set { this.RaiseAndSetIfChanged(ref _elementsToTake, value) }
}

public int Sum
{
    get { return _sum.Value; }
}

public MyViewModel
{
    var elementsToTakeObservable = this
        .WhenAny(x => x.ElementsToTake, x => x.Value);
    _collection.ChangeTrackingEnabled = true;
    //here I'm adding some objects to _collection
    var sumObservable = _collection.ItemChanged
        .CombineLatest(elementsToTakeObservable,
            (_, c) => _collection.Take(c)
                .Aggregate(0, (i, x) => i + x.NumberToSum))).
        .ToProperty(this, x => x.Sum, out _sum, 0);
}

因此，我使用 ReactiveList.ItemChanged 来跟踪 _collection 项中的更改。每次发生变化时，都会重新计算总和。这里的问题是合并到 sumObservable 中的 observables 的初始值。我可以通过为 ElementsToTake 属性赋值轻松设置 elementsToTakeObservable 的初始值，这将引发属性更改事件和内容。但是对于 _collection.ItemChanged observable 来说并不是那么容易。我需要至少让 _collection 中的一个对象引发 propertychanged 事件，但这看起来很糟糕。可以设置这些初始值吗？或者也许我这样做完全错了？

Answer 1

StartWith 将解决您的问题。此外，我不确定您是否需要 ItemChanged，它会在 列表中的项 更改时发出信号，而不是在添加或删除项时发出信号。在这里，您可能还想听听 Changed。

虽然尝试以这种方式保持“运行总计”很诱人，但由于重置和移动的原因，实际上很难正确地做到这一点。一种更简单的方法是滥用 CPU 非常快这一事实，并在每次更改时重新计算它:

_collection.ChangeTrackingEnabled = true;

Observable.Merge(
         _collection.Changed.Select(_ => Unit.Default), 
         _collection.ItemChanged.Select(_ => Unit.Default))
    .Select(_ => _collection.Sum(x => x.NumberToSum));

另一种不太适合像这样的聚合但也非常有用的方法是 ActOnEveryObject ，它将对列表中的每个项目执行一个 block ，并正确处理初始化、重置和移动。