我有一个。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重构。:)
顺便说一句,测试类的构造函数包含了下面的语句来实现线程化:
不要这样做
我的问题基本上是,我的视图上的Refresh()方法从未被调用后,我改变了FilterText,我看不出为什么不。
我认为你的问题是被注释掉的部分:
.Throttle (TimeSpan.FromMilliseconds (300)/, RxApp.TaskpoolScheduler /)
和这部分:
.ObserveOnDispatcher ()
使用TestScheduler时,必须使用RxApp。[MainThread/Taskpool] 所有调度程序参数的调度程序。在上面,您使用了一个real TaskpoolScheduler和一个real Dispatcher。因为它们不在TestScheduler之下,所以它们不能被TestScheduler控制。
相反,写:
this.WhenAnyValue(x => x.FilterText)
.Throttle(TimeSpan.FromMilliseconds(300), RxApp.TaskpoolScheduler)
.DistinctUntilChanged()
.ObserveOn(RxApp.MainThreadScheduler)
.Subscribe(_ => _packetView.Refresh());
和一切都应该工作。