使用FromAsyncPattern进行单元测试

反应式扩展有一个有趣的小钩子来简化调用异步方法:

var func = Observable.FromAsyncPattern<InType, OutType>(
    myWcfService.BeginDoStuff,
    myWcfService.EndDoStuff);

func(inData).ObserveOnDispatcher().Subscribe(x => Foo(x));

我在一个WPF项目中使用它,它在运行时工作得很好。

不幸的是,在尝试使用这种技术的单元测试方法时,我遇到了随机失败。大约每执行五次包含此代码的测试中有三次失败。

下面是一个示例测试(使用Rhino/Unity自动模拟容器实现):

[TestMethod()]
public void SomeTest()
{
   // arrange
   var container = GetAutoMockingContainer();

   container.Resolve<IMyWcfServiceClient>()
      .Expect(x => x.BeginDoStuff(null, null, null))
      .IgnoreArguments()
      .Do(
         new Func<Specification, AsyncCallback, object, IAsyncResult>((inData, asyncCallback, state) =>
            {
               return new CompletedAsyncResult(asyncCallback, state);
             }));

   container.Resolve<IRepositoryServiceClient>()
      .Expect(x => x.EndDoStuff(null))
      .IgnoreArguments()
      .Do(
         new Func<IAsyncResult, OutData>((ar) =>
         {
            return someMockData;
         }));

   // act
   var target = CreateTestSubject(container);

   target.DoMethodThatInvokesService();

   // Run the dispatcher for everything over background priority
   Dispatcher.CurrentDispatcher.Invoke(DispatcherPriority.Background, new Action(() => { }));

   // assert
   Assert.IsTrue(my operation ran as expected);
}

我看到的问题是,我指定在异步操作完成时运行的代码(在本例中是foo(x))从未被调用。我可以通过在foo中设置断点并观察它们从未到达来验证这一点。此外,我可以在调用调用调用服务(它启动异步调用)的domethodthatinvokesseservice之后强制长时间延迟,代码仍然不会运行。我 做 知道调用RX框架的代码行是被调用的。

我尝试过的其他事情:

• 我试图根据以下建议修改最后一行: Reactive Extensions Rx - unit testing something with ObserveOnDispatcher 没有爱。

• 我补充说 .Take(1) 接收代码如下:

  func(indata).observeOnDispatcher().take(1).subscribe(x=>foo(x));

这使我的失败率提高到了1/5,但仍然发生了。

• 我已经重写了RX代码以使用普通的Jane异步模式。这是可行的,但是我的开发人员非常希望使用RX而不是无聊的旧的开始/结束。

最后,我确实手头有一份工作(即不要使用RX),但我觉得这并不理想。如果过去有人碰到这个问题并找到了解决办法,我很想听听。

更新 :

我也 posted on the Rx forums 它们将包括一个测试调度程序和一个即将发布的版本。这可能是最终的解决方案,一旦它可用。