从 SortedList 中 T.MyProperty 上的所有 Property Changed 事件中获取 IObservable

我有一个班级，MyClass实现INotifyPropertyChanged并且有一些实现的属性PropertyChanged. When MyClass.MyProperty变化，PropertyChanged如预期那样起火。另一个类包含一个SortedList<MyClass>.我尝试将事件合并到包含以下内容的类中的单个可观察对象中SortedSet<MyClass>并订阅它，但它似乎没有任何事件。这就是我正在尝试的：

Observable.Merge(MySortedList.ToObservable())
   .Subscribe(evt => Console.WriteLine("{0} changed", evt.MyProperty));

我想要得到的是一个单一的可观察对象，其中包含我的每个项目的所有事件SortedList<MyClass>。我尝试使用 ObservableCollection 来代替，但这不会改变任何东西，实际上也不会改变任何东西，因为无论如何，当所包含项目的属性发生变化时它不会触发 collectionchanged 。我可以聆听其中的各个元素SortedList<MyClass>并看到 PropertyChanged 事件触发，但我想要的是一个单一的 Observable，其中包含来自所有元素的所有 PropertyChanged 事件的流SortedList<MyClass>.

看起来这应该是使用 Rx 相当容易做到的事情，但我似乎不知道如何做。

我为 RxCookBook 撰写了一篇关于此主题的文章，您可以在这里找到https://github.com/LeeCampbell/RxCookbook/blob/master/Model/CollectionChange.md https://github.com/LeeCampbell/RxCookbook/blob/master/Model/CollectionChange.md有关 PropertyChange 通知的更多文章请参见此处https://github.com/LeeCampbell/RxCookbook/blob/master/Model/PropertyChange.md https://github.com/LeeCampbell/RxCookbook/blob/master/Model/PropertyChange.md

它通过聚合来自某个项目的更改来解决您需要的问题ObservableCollection<T>。通过使用ObservableCollection<T>当在集合中添加或删除项目时，您还会收到通知。

如果您不想使用ObservableCollection<T>（即您只想跟踪集合的给定快照的属性）那么您将需要执行其他操作。首先我假设你有一个INoftifyPropertyChanged to IObservable<T>扩展方法或者您只需使用标准事件IObservable<T>方法。

接下来，您可以将值列表投影到更改序列列表中，即IEnumerable<T> to IEumerable<IObserable<T>>。这允许您使用Observable.Merge将更改列表扁平化为单个stream的变化。

如果您不想使用上面的链接，这里有一个示例：

void Main()
{
    var myList = new List<MyThing>{
        new MyThing{Name="Lee", Age=31},
        new MyThing{Name="Dave", Age=37},
        new MyThing{Name="Erik", Age=44},
        new MyThing{Name="Bart", Age=24},
        new MyThing{Name="James", Age=32},
    };

    var subscription = Observable.Merge(myList.Select(t=>t.OnAnyPropertyChanges()))
                .Subscribe(x=>Console.WriteLine("{0} is {1}", x.Name, x.Age));

    myList[0].Age = 33;
    myList[3].Name = "Bob";

    subscription.Dispose();
}

// Define other methods and classes here
public class MyThing : INotifyPropertyChanged
{
private string _name;
private int _age;

public string Name
{
    get { return _name; }
    set
    {
        _name = value;
        OnPropertyChanged("Name");
    }
}

public int Age
{
    get { return _age; }
    set
    {
        _age = value;
        OnPropertyChanged("Age");
    }
}

public event PropertyChangedEventHandler PropertyChanged;

protected virtual void OnPropertyChanged(string propertyName)
{
    var handler = PropertyChanged;
    if (handler != null) handler(this, new PropertyChangedEventArgs(propertyName));
}
}

public static class NotificationExtensions
{
    /// <summary>
    /// Returns an observable sequence of the source any time the <c>PropertyChanged</c> event is raised.
    /// </summary>
    /// <typeparam name="T">The type of the source object. Type must implement <seealso cref="INotifyPropertyChanged"/>.</typeparam>
    /// <param name="source">The object to observe property changes on.</param>
    /// <returns>Returns an observable sequence of the value of the source when ever the <c>PropertyChanged</c> event is raised.</returns>
    public static IObservable<T> OnAnyPropertyChanges<T>(this T source)
        where T : INotifyPropertyChanged
    {
            return Observable.FromEventPattern<PropertyChangedEventHandler, PropertyChangedEventArgs>(
                                handler => handler.Invoke,
                                h => source.PropertyChanged += h,
                                h => source.PropertyChanged -= h)
                            .Select(_=>source);
    }
}

这将输出：

Lee is 33
Bob is 24