Как связать ObservableCollection <T>изменяемой модели с ReadOnlyObservableCollection <T>модели представления с использованием ReactiveUI и DynamicData - PullRequest
Новая
       39

Как связать ObservableCollection <T>изменяемой модели с ReadOnlyObservableCollection <T>модели представления с использованием ReactiveUI и DynamicData

2 голосов
/ 05 февраля 2020

Я использую ReactiveUI и DynamicData в моем C# проекте. Однако классы доменной модели по-прежнему полагаются на события C#, интерфейсы INotifyPropertyChanged и INotifyCollectionChanged.

Существуют классы Model и ViewModel: 

public class Model
{
    public ObservableCollection<int> Collection { get; } = new ObservableCollection<int>();
}

public class ViewModel : ReactiveObject, IDisposable
{
    private readonly CompositeDisposable _cleanUp;
    private readonly SourceList<int> _collectionForCurrentBModel = new SourceList<int>();
    private Model _model = new Model();
    private IDisposable _tempCleanUp = Disposable.Empty;

    public ViewModel()
    {
        _cleanUp = new CompositeDisposable();
        _collectionForCurrentBModel.Connect()
            .Bind(out var aModelsForCurrentBModel)
            .Subscribe(Console.WriteLine)
            .DisposeWith(_cleanUp);
        CollectionForCurrentBModel = aModelsForCurrentBModel;

        this.WhenAnyValue(x => x.Model.Collection) // Every time Model in ViewModel changes:
            .Subscribe(collection =>
            {
                // we dispose previous subscription:
                _tempCleanUp.Dispose();
                // then we manually reset SourceList<int> to match new collection:
                _collectionForCurrentBModel.Edit(x =>
                {
                    x.Clear();
                    x.AddRange(collection);
                });
                // finally, we manually subscribe to ObservableCollection<int>'s events to synchronize SourceList<int>.
                _tempCleanUp = collection.ObserveCollectionChanges().Subscribe(pattern =>
                {
                    switch (pattern.EventArgs.Action)
                    {
                        case NotifyCollectionChangedAction.Add:
                            _collectionForCurrentBModel.AddRange(pattern.EventArgs.NewItems.Cast<int>());
                            break;
                        case NotifyCollectionChangedAction.Remove:
                            _collectionForCurrentBModel.RemoveRange(pattern.EventArgs.OldStartingIndex,
                            pattern.EventArgs.OldItems.Count);
                            break;
                        case NotifyCollectionChangedAction.Replace:
                            for (var i = 0; i < pattern.EventArgs.NewItems.Count; i++)
                                _collectionForCurrentBModel.Replace((int) pattern.EventArgs.OldItems[i],
                                (int) pattern.EventArgs.NewItems[i]);
                            break;
                        case NotifyCollectionChangedAction.Move:
                            break;
                        case NotifyCollectionChangedAction.Reset:
                            break;
                        default:
                            throw new ArgumentOutOfRangeException();
                    }
                });
            });
    }

    public ReadOnlyObservableCollection<int> CollectionForCurrentBModel { get; }

    public Model Model
    {
        get => _model;
        set => this.RaiseAndSetIfChanged(ref _model, value);
    }

    public void Dispose()
    {
        _cleanUp.Dispose();
    }
}

Итак, ViewModel имеет свойство Model. Текущая модель может быть изменена на другую. ViewModel также имеет свойство CollectionForCurrentModel, которое в этом примере в основном равно его 'source (Model.Collection) (однако предполагается, что должна быть некоторая сортировка, фильтрация и т. Д. c.). Свойство CollectionForCurrentModel должно быть доступно только для чтения. Приведенный ниже код работает должным образом: 

private static void Main(string[] args)
{
    using var viewModel = new ViewModel();
    // viewModel.Collection: {}
    viewModel.Model.Collection.Add(0);
    // viewModel.Collection: {0}
    viewModel.Model.Collection.Add(1);
    // viewModel.Collection: {0, 1}
    var oldModel = viewModel.Model;
    viewModel.Model = new Model();
    // viewModel.Collection: {}
    viewModel.Model.Collection.Add(2);
    // viewModel.Collection: {2}
    oldModel.Collection.Add(3);
    // viewModel.Collection: {2}
}

Однако добавление нового поля в ViewModel для хранения последней подписки, отписки от нее вручную и синхронизации коллекций вручную выглядит довольно уродливо. Есть ли другой способ подписаться на: 

IObservable<IObservable<IChangeSet<T>>>
\\ is result of
this.WhenAnyValue(x => x.ObservableCollection, selector: collection => collection.ToObservableChangeSet();

? Может ли DynamicData автоматически управлять внутренними подписками, чтобы связать наблюдаемую коллекцию в изменяемом свойстве с другой коллекцией?

1 Ответ

3 голосов
/ 05 февраля 2020

Это должно быть легко. Вы можете сделать что-то вроде этого: 

this.WhenAnyValue(x => x.Model.Collection)
    .Select(collection => collection.ToObservableChangeSet())
    .Switch() //this is the dynamic data overload of rx.Switch() 
    .Bind(out var aModelsForCurrentBModel)
    .Subscribe();

Оператор select возвращает наблюдаемый набор наблюдаемых изменений, который сам по себе не очень полезен. Вот почему оператор switch требуется. Когда коллекция установлена, она удаляет существующие элементы из своего кэша и загружает элементы из новой наблюдаемой коллекции. После этого вы можете просто выполнить привязку к целевой наблюдаемой коллекции.

Использование этого метода означает, что нет необходимости вручную поддерживать список источников.

...