c# - 观察两个 ReactiveLists 上的 ItemChanged

Question

我有一个 ViewModel，我想在其中监听两个 ReactiveLists、Payments 和 AccountPayments 中项目的更改。列表被实例化并且 ChangeTrackingEnabled 设置为 true:

this.Payments = new ReactiveList<transaction.PaymentViewModel>();
this.Payments.ChangeTrackingEnabled = true;`
this.AccountPayments = new ReactiveList<AccountPaymentViewModel>();
this.AccountPayments.ChangeTrackingEnabled = true;`

然后，在我的 ViewModel 中定义了一个 ObservableAsPropertyHelper 只读属性:

readonly ObservableAsPropertyHelper<decimal> _totalPayments;
public decimal TotalPayments { get { return _totalPayments.Value; } }

我的意图是在两个列表中的任何这些项目发生变化时设置 TotalPayments。我尝试使用 WhenAny:

this.WhenAny(vm => vm.Payments.ItemChanged,
            vm => vm.AccountPayments.ItemChanged,
            (a, b) => a.Sender.Payments
                .Where(x => x.Amount.HasValue).Sum(x => x.Amount.Value)
                + b.Sender.AccountPayments
                .Where(x => x.Amount.HasValue).Sum(x => x.Amount.Value))
            .ToProperty(this, vm => vm.TotalPayments, out _totalPayments);

虽然编译得很好，但它似乎没有捕捉到变化。我还尝试使用 WhenAnyObservable:

this.WhenAnyObservable(
            vm => vm.Payments.ItemChanged,
            vm => vm.AccountPayments.ItemChanged)
            .Select(_ =>
                this.Payments.Where(x => x.Amount.HasValue)
                    .Sum(x => x.Amount.Value)
                + this.AccountPayments.Where(x => x.Amount.HasValue)
                    .Sum(x => x.Amount.Value))
            .ToProperty(this, vm => vm.TotalPayments, out _totalPayments);

但这不会编译。有没有办法完成我想做的事情？任何帮助将不胜感激。

Answer 1

第一个不起作用，因为它正在观察属性变化，而 ItemChanged 本身不会改变，它是一个可观察对象。

第二个几乎是正确的，但需要进行一些修改。 WhenAnyObservable 要求所有可观察对象都是同一类型。由于您对实际结果不感兴趣，您可以选择 Unit 并将两者合并:

this.WhenAnyObservable(a => a.Payments.ItemChanged).Select(_ => Unit.Default)
    .Merge(this.WhenAnyObservable(a => a.AccountPayments.ItemChanged).Select(_ => Unit.Default));

您不能在 WhenAnyObservable 中选择 Unit.Default，因为它会重写此表达式以观察属性更改，以确保它具有最新的可观察值。如果 Payments 和 AccountPayments 都不会改变(即它们是只读的)，您可以完全省略 WhenAnyObservable:

Payments.ItemChanged.Select(_ => Unit.Default)
    .Merge(AccountPayments.ItemChanged.Select(_ => Unit.Default));