如何在 ReactiveUI 中使用 WhenAny(...) 合并多个可观察值？

我有一个问题，它是本网站上提出的以下问题的延伸。

当返回类型不重要时，是否有更优雅的方法来合并可观察量？ https://stackoverflow.com/questions/8010372/is-there-a-more-elegant-way-to-merge-observables-when-return-type-is-unimportant/21762027#21762027

我有一个IObservable<Unit>（可以说X），反应式集合（Y）和属性（Z）。返回类型并不重要。我只想在其中任何一个发生变化时订阅。

我知道如何观察所有 3 个并且Subscribe using Observable.Merge如下。

Observable.Merge(X, Y.Changed, ObservableForProperty(Z).Select(_ => Unit.Default)).Subscribe(..)

它有效。

但是，当我尝试使用WhenAny(...,....,....).Subscribe()，当我的X变化。使用执行上述操作的语法是什么WhenAny(...)而不是Observable.Merge(..)??

我更喜欢使用WhenAny(....)因为我正在使用ReactiveUI在其他地方。

例子： 假设我有一个派生类ReactiveObject具有以下属性。

public class AnotherVM : ReactiveObject
{
    public bool IsTrue
    {
        get { return this.isTrue; }
        set { this.RaiseAndSetIfChanged(x => x.isTrue, ref this.isTrue, value); }
    }

    public IObservable<Unit> Data
    {
        get { return this.data; }
    }

    public ReactiveCollection MyCol
    {
       get { return Mycol; }
    }    
}

public class MyVM : ReactiveObject
{
    MyVM
    {
       // do WhenAny or Observable.Merge here....
    }
}

我想观察上述属性AnotherVM类使用Observable.Merge(..) or WhenAny(...) in MyVM班级。我发现当我订阅上述内容时并不总是收到通知MyVM using WhenAny(...) or Merge(...)当这 3 个属性中的任何一个发生变化时。

WhenAny不是用于跨任意可观察值集进行监视，而是用于监视 ReactiveUI 支持的对象的属性（例如 ReactiveObject 或反应式集合）。

对于组合可观察流中的变化的一般情况，Observable.Merge是正确的方法。

EDIT

我注意到您已将 Data 和 MyCol 属性声明为只读。如果您使用Merge像这样：

Observerable.Merge(this.WhenAnyValue(o=>o.IsTrue, v=>Unit.Default),
                   this.Data,
                   this.MyCol.CollectionChanged.Select(v=>Unit.Default))

...那么您必须小心不要更改支持字段。如果你这样做，那么你会丢失事件 - 也许这就是正在发生的事情？

在这种情况下，您需要将这些属性连接到RaiseAndSetIfChanged并使用Switch跟踪 - 例如如果this.data可以更改然后您需要（我在这里使用 ReactiveUI 5 + .NET 4.5，以防 RaiseAndSetIfChanged 语法看起来很奇怪）：

public IObservable<Unit> Data
{
    get { return this.data; }
    private set { this.RaiseAndSetIfChanged(ref data, value); }
}

你的合并将是这样的：

Observerable.Merge(this.WhenAnyValue(o=>o.IsTrue, v=>Unit.Default),
                   this.WhenAnyObservable(x => x.Data),
                   this.MyCol.CollectionChanged.Select(v=>Unit.Default))

WhenAnyObservable 在概念上等价于：

WhenAny(x => x.Data, vm => vm.Value).Switch()

使用 Switch 翻转到最新值Data当它改变时。不要忘记使用设置器来更改数据值！