ReactiveUI vs. ICollectionView

我有一个。net 4.5应用程序，它正在迁移到基于wpf的RxUI(保持最新，在撰写本文时为6.0.3)。我有一个文本字段，它应该作为一个过滤器字段与相当常见的节流等东西，这是一个原因的一部分，首先要反应。

这是我课上的相关部分。

public class PacketListViewModel : ReactiveObject
{
    private readonly ReactiveList<PacketViewModel> _packets;
    private PacketViewModel _selectedPacket;
    private readonly ICollectionView _packetView;
    private string _filterText;
    /// <summary>
    /// Gets the collection of packets represented by this object
    /// </summary>
    public ICollectionView Packets 
    {
        get
        {
            if (_packets.Count == 0)
                RebuildPacketCollection();
            return _packetView;
        }
    }
    public string FilterText
    {
        get { return _filterText; }
        set { this.RaiseAndSetIfChanged(ref _filterText, value); }
    }
    public PacketViewModel SelectedPacket
    {
        get { return _selectedPacket; }
        set { this.RaiseAndSetIfChanged(ref _selectedPacket, value); }
    }
    public PacketListViewModel(IEnumerable<FileViewModel> files)
    {
        _packets = new ReactiveList<PacketViewModel>();
        _packetView = CollectionViewSource.GetDefaultView(_packets);
        _packetView.Filter = PacketFilter;
        _filterText = String.Empty;
        this.WhenAnyValue(x => x.FilterText)
            .Throttle(TimeSpan.FromMilliseconds(300)/*, RxApp.TaskpoolScheduler*/)
            .DistinctUntilChanged()
            .ObserveOnDispatcher()
            .Subscribe(_ => _packetView.Refresh());
    }
    private bool PacketFilter(object item)
    {
        // Filter logic
    }
    private void RebuildPacketCollection()
    {
        // Rebuild packet list from data source
        _packetView.Refresh();
    }
}

我使用Xunit.net和Resharper的测试运行器进行单元测试。我创建了一些测试数据并运行这个测试:

[Fact]
public void FilterText_WhenThrottleTimeoutHasPassed_FiltersProperly()
{
    new TestScheduler().With(s =>
    {
        // Arrange
        var fvm = GetLoadedFileViewModel();
        var sut = new PacketListViewModel(fvm);
        var lazy = sut.Packets;
        // Act
        sut.FilterText = "Call";
        s.AdvanceToMs(301);
        // Assert
        var res = sut.Packets.OfType<PacketViewModel>().ToList();
        sut.Packets.OfType<PacketViewModel>()
           .Count().Should().Be(1, "only a single packet should match the filter");
    });
}

我在类的构造函数中为我的FilterText配置的订阅操作上放置了一条调试语句，并且它在启动时为每个包项调用一次，但在我更改FilterText属性后它永远不会被调用。

顺便说一句，测试类的构造函数包含了下面的语句来实现线程化:

SynchronizationContext.SetSynchronizationContext(new SynchronizationContext());

我的问题基本上是，我的视图上的刷新()方法从未被调用后，我改变了FilterText，我看不出为什么不。

这是一个简单的问题与我的代码?或者这是一个问题与CollectionViewSource的东西运行在一个单元测试上下文中，而不是在WPF上下文中?

我应该放弃这个想法，而宁愿有一个ReactiveList属性，当文本更改被触发时，我手动过滤?

注意:这在应用程序中工作- FilterText触发那里的更新。它只是没有发生在单元测试中，这让我怀疑我是否做错了。

EDIT:按照要求，这里是XAML的相关部分-这现在只是一个简单的窗口，包含一个文本框和一个数据网格。

文本框:

<TextBox Name="FilterTextBox"
         Grid.Column="1"
         VerticalAlignment="Center"
         Text="{Binding FilterText, Mode=TwoWay, UpdateSourceTrigger=PropertyChanged}"
         />

datagrid:

<DataGrid ItemsSource="{Binding Path=Packets}"
          Name="PacketDataGrid"
          SelectedItem="{Binding SelectedPacket}"
          AutoGenerateColumns="False"
          EnableRowVirtualization="True"
          SelectionMode="Single"
          SelectionUnit="FullRow"
          CanUserAddRows="False"
          CanUserResizeRows="False"
          >
    <DataGrid.Columns>
...

如果有任何其他相关的/需要的，让我知道!

EDIT 2: Paul Betts建议不要像我一样在测试构造函数中进行SynchronizationContext设置，可能有非常合理的理由。然而，我这样做是因为另一个视图模型(FileViewModel)的工作方式——它需要等待MessageBus消息来知道包处理已经完成。这是我正在积极努力避免的事情——我知道MessageBus是一个非常方便的坏主意。:)但这是SyncContext东西的原因。创建测试视图模型的方法如下所示:

private FileViewModel GetLoadedFileViewModel()
{
    var mre = new ManualResetEventSlim();
    var fvm = new FileViewModel(new MockDataLoader());
    MessageBus.Current
              .Listen<FileUpdatedPacketListMessage>(fvm.MessageToken.ToString())
              .Subscribe(msg => mre.Set());
    fvm.LoadFile("irrelevant.log");
    mre.Wait(500);
    return fvm;
}

我知道这是糟糕的设计，所以请不要大喊大叫。,)但是我在这里把很多遗留代码移到了基于RxUI的MVVM中——我不可能做完所有的事情，最后得到一个完美的设计，这就是为什么我要对所有这些东西进行单元测试，这样我就可以在以后进行Rambo重构。:)

    this.WhenAnyValue(x => x.FilterText)
        .Throttle(TimeSpan.FromMilliseconds(300), RxApp.TaskpoolScheduler)
        .DistinctUntilChanged()
        .ObserveOn(RxApp.MainThreadScheduler)
        .Subscribe(_ => _packetView.Refresh());