Я изучал использование Rx в рамках MVVM. Идея состоит в том, чтобы использовать «живые» запросы LINQ к наборам данных в памяти для проецирования данных в модели представления для привязки.
Ранее это было возможно с использованием INotifyPropertyChanged/INotifyCollectionChanged и библиотеки с открытым исходным кодом под названием CLINQ. Потенциал Rx и IObservable заключается в переходе к гораздо более декларативной ViewModel с использованием классов Subject для распространения измененных событий из исходной модели в представление. Для последнего шага потребуется преобразование IObservable в обычные интерфейсы привязки данных.
Проблема в том, что Rx не поддерживает уведомление об удалении объекта из потока. Пример ниже.
В коде показан POCO, в котором для состояния поля используется класс BehaviorSubject. Далее код создает коллекцию этих сущностей и использует Concat для объединения потоков фильтров. Это означает, что о любых изменениях в POCO сообщается в один поток.
Фильтр для этого потока настроен на фильтрацию для рейтинга == 0. Подписка просто выводит результат в окно отладки, когда происходит даже.
Настройки Rating=0 для любого элемента вызовут событие. Но установка рейтинга обратно на 5 не приведет ни к каким событиям.
В случае CLINQ вывод запроса будет поддерживать INotifyCollectionChanged, так что элементы, добавленные и удаленные из результата запроса, вызовут правильное событие, указывающее, что результат запроса изменился (элемент добавлен или удален).
Единственный способ, которым я могу придумать адрес, - настроить два потока с противоположными (двойными) запросами. Элемент, добавленный в противоположный поток, подразумевает удаление из набора результатов. В противном случае я мог бы просто использовать FromEvent и не делать ни одну из моделей сущностей наблюдаемой, что делает Rx больше просто агрегатором событий. Любые указатели?
using System;
using System.ComponentModel;
using System.Linq;
using System.Collections.Generic;
namespace RxTest
{
public class TestEntity : Subject<TestEntity>, INotifyPropertyChanged
{
public IObservable<string> FileObservable { get; set; }
public IObservable<int> RatingObservable { get; set; }
public string File
{
get { return FileObservable.First(); }
set { (FileObservable as IObserver<string>).OnNext(value); }
}
public int Rating
{
get { return RatingObservable.First(); }
set { (RatingObservable as IObserver<int>).OnNext(value); }
}
public event PropertyChangedEventHandler PropertyChanged;
public TestEntity()
{
this.FileObservable = new BehaviorSubject<string>(string.Empty);
this.RatingObservable = new BehaviorSubject<int>(0);
this.FileObservable.Subscribe(f => { OnNotifyPropertyChanged("File"); });
this.RatingObservable.Subscribe(f => { OnNotifyPropertyChanged("Rating"); });
}
private void OnNotifyPropertyChanged(string property)
{
if (PropertyChanged != null) PropertyChanged(this, new PropertyChangedEventArgs(property));
// update the class Observable
OnNext(this);
}
}
public class TestModel
{
private List<TestEntity> collection { get; set; }
private IDisposable sub;
public TestModel()
{
this.collection = new List<TestEntity>() {
new TestEntity() { File = "MySong.mp3", Rating = 5 },
new TestEntity() { File = "Heart.mp3", Rating = 5 },
new TestEntity() { File = "KarmaPolice.mp3", Rating = 5 }};
var observableCollection = Observable.Concat<TestEntity>(this.collection.Cast<IObservable<TestEntity>>());
var filteredCollection = from entity in observableCollection
where entity.Rating==0
select entity;
this.sub = filteredCollection.Subscribe(entity =>
{
System.Diagnostics.Debug.WriteLine("Added :" + entity.File);
}
);
this.collection[0].Rating = 0;
this.collection[0].Rating = 5;
}
};
}
