时间戳

首页 > 解决方案 > AutoRefreshOnObservable 只工作一次。为什么？

wpf - AutoRefreshOnObservable 只工作一次。为什么？

问题描述

我正在开发一个小程序，我正在评估反应式 ui 是否是另一个项目的正确框架。到目前为止一切顺利......目前我有点迷失在 DynamicData 相关功能中。每次更改 ReactiveUserControl 中的组合框时，我都会尝试在 MainViewWindow 中执行命令。我所有的模型都在扩展 ReactiveObject，并且属性是使用 RaiseAndSetIfChanged 设置器设置的。

在我的 ReactiveUserControl ViewModel 中，我从 ReactiveUserControl ViewModel 调用我的命令 SaveImage，如下所述： https ://reactiveui.net/docs/handbook/message-bus/#ways-to-avoid-using-messagebus

定义 ObservableCollection


public ObservableCollection<FileViewModel> VisibleFiles { get; protected set; }

初始化Collection，Files是一个SourceList


 WatchFiles = ReactiveCommand.Create(() =>
            {
                VisibleFiles = new ObservableCollection<FilesViewModel>(Files.Items);
VisibleFiles.ToObservableChangeSet().AutoRefreshOnObservable(doc => doc.SaveImage).Select(_ => WhenAnyFileChanged()).Switch().Subscribe<FilesViewModel>(x => {
                    Console.WriteLine("HOORAY");
                });

            });



 private IObservable<FilesViewModel> WhenAnyFileChanged()
        {
            return VisibleFiles.Select(x => x.SaveFile.Select(_ => x )).Merge();
        }

第一次更改组合框时，它会被正确评估。我得到了“万岁”。但是之后每次都没有输出。如果我再次调用 Watch Files 命令，它会再次工作一次。为什么会发生这种情况，每次文件更改“万岁”时，我该如何解决打印？我可以看到，ObservableCollection 检测到更改，并且在更改时调用 ReactiveUserControl 中的命令。但是 WhenAnyFileChanged 方法在第一次调用后不会返回更改的元素。希望我想要达到的目标是可以理解的，问题是什么。

更新：我不知道为什么，但是如果我在 Select() 中检查 ChangeSet，我会在初始化时得到 TotalChanges 10，这是正确的。然后我的第一个工作更改 TotalChanges 为 0 但评估正确。在我下次尝试更改时，我仍然得到 0 TotalChanges，但在 WhenAnyFileChanged() 中也没有正确的评估。Refreshes() 在每次更改时为 1。

更新 2：将 AutoRefreshOnObservable() 更改为 AutoRefresh() 会带来所需的功能。

标签： wpfdynamic-datareactiveui

解决方案

我复制了原始消息总线示例并编写了一个单元测试，以查看代码是否按预期运行。我可以确认示例中存在您所看到的问题。以下代码仅触发一次。

public MainViewModel()
{
    OpenDocuments = new ObservableCollection<DocumentViewModel>();

    OpenDocuments
        .ToObservableChangeSet()
        .AutoRefreshOnObservable(document => document.Close)
        .Select(_ => WhenAnyDocumentClosed())
        .Switch()
        .Subscribe(x => OpenDocuments.Remove(x), ex=>{},()=>{});
}

IObservable<DocumentViewModel> WhenAnyDocumentClosed()
{
    return OpenDocuments
        .Select(x => x.Close.Select(_ => x))
        .Merge();
}

这是证明它的测试。它在第二次尝试删除时失败。

[Fact]
public void MyTest()
{
    //I added an id field to help with diagnostics / testing
    _mainViewModel.OpenDocuments.Count.Should().Be(4);
    _mainViewModel.OpenDocuments.Any(dvm => dvm.Id == "1").Should().BeTrue();

    _mainViewModel.OpenDocuments[0].Close.Execute().Subscribe();
    _mainViewModel.OpenDocuments.Count.Should().Be(3);
    _mainViewModel.OpenDocuments.Any(dvm => dvm.Id == "1").Should().BeFalse();


    _mainViewModel.OpenDocuments[0].Close.Execute().Subscribe();
    _mainViewModel.OpenDocuments.Count.Should().Be(2);
    _mainViewModel.OpenDocuments.Any(dvm => dvm.Id == "2").Should().BeFalse();
}

我不确定为什么会失败，但最优化的解决方法是使用 Dynamic Data 的MergeMany运算符，它与 Rx 的运算符类似，Merge但在将项目添加到基础列表时自动连接可观察对象，并在删除项目时取消连接它们。修复方法是：

public class MainViewModel : ReactiveObject
{
    public ObservableCollection<DocumentViewModel> OpenDocuments { get;}

    public MainViewModel()
    {
        OpenDocuments = new ObservableCollection<DocumentViewModel>();

        OpenDocuments
            .ToObservableChangeSet()
            .MergeMany(x => x.Close.Select(_ => x))
            .Subscribe(x => OpenDocuments.Remove(x));
    }
}

运行相同的单元测试通过。

此要点中提供了带有单元测试的代码

推荐阅读