Объединить события PropertyChanged из коллекции в один IObservable‹EventPattern‹PropertyChangedEventArgs››

У меня есть коллекция объектов INotifyPropertyChanged, и я хотел бы передать все события PropertyChanged в одну наблюдаемую последовательность для дальнейшей обработки.

Вот код

IObservable<EventPattern<PropertyChangedEventArgs>> _allEvents = null;

                // Items contains collection of item, which implements INotifyPropertyChanged
                foreach (var item in Items)
                {
                    var seq = Observable.FromEventPattern<PropertyChangedEventArgs>(item, "PropertyChanged");

                    if (_allEvents == null)
                        _allEvents = seq;
                    else
                        _allEvents.Merge(seq);
                }

                // subscribe to the aggregated observable sequence
                if (_allEvents != null)
                    _allEvents.Subscribe(evt => Trace.WriteLine(" Property Changed -> " + evt.EventArgs.PropertyName));

Одиночная подписка здесь почему-то не работает в агрегированной последовательности. Похоже, я неправильно агрегировал (используя функцию слияния Reactive Extensions). Но подписка внутри цикла работает отлично.

Может ли кто-нибудь помочь мне здесь, как объединить множество потоков событий в один с реактивными расширениями?

Спасибо


reactive-programming system.reactive reactiveui
person user1153896    schedule 21.02.2012    source источник

Ответы (1)


arrow_upward
1
arrow_downward

Попробуй это:

var _allEvents = Observable
   .Merge(Items
       .Select(item => Observable
           .FromEventPattern<PropertyChangedEventArgs>(item, "PropertyChanged")));

_allEvents.Subscribe(evt => Trace.WriteLine(" Property Changed -> " + evt.EventArgs.PropertyName));

Причина, по которой ваш подход не работает, заключается в том, что вы звонили IObservable<T> Observable.Merge<T>(this IObservable<T> first, IObservable<T> second). Тип возвращаемого значения — результирующий наблюдаемый. Я думаю, вы могли подумать, что Merge изменил Observable, но вы можете думать о Observables как о неизменных (вроде). Чтобы получить ваш подход к работе, можно было бы:

_allEvents = _allEvents.Merge(seq);

Но... тьфу. Не делай этого.

person Anderson Imes    schedule 21.02.2012