如何使用 TestScheduler 完成超时行为？

Question

我创建了以下辅助方法来帮助测试可观察对象：

    public static void ExecuteObservableTest<T>(IObservable<T> observable, Action action, Action assert, bool expectTimeout, int timeout = 500)
    {
        Exception ex = null;
        var scheduler = new TestScheduler();
        observable.Timeout(TimeSpan.FromMilliseconds(timeout)).ObserveOn(scheduler).Subscribe(_ => { }, e => ex = e);
        action();
        scheduler.AdvanceBy(TimeSpan.FromMilliseconds(timeout).Ticks + 1);
        assert();
        if (expectTimeout) Assert.IsNotNull(ex);
        else Assert.IsNull(ex);
    }

只要我不期待超时，一切都会很好。对于我确实期望超时的测试用例，此方法永远不会到达 OnException 方法。使用 TestScheduler 实现此目的的正确方法是什么？

我还应该注意超时是一个软超时，这意味着如果可观察对象没有在分配的时间内完成，它永远不会完成 - 但在可观察对象本身中没有定义相应的超时。

Answer 1

您需要将 TestScheduler 提供给 Timeout 和 this overload

var scheduler = new TestScheduler();
observable.Timeout( TimeSpan.FromMilliseconds(timeout), scheduler)
          .Subscribe(_ => { }, e => ex = e);

如何使用 TestScheduler 完成超时行为？

How to accomplish timeout behavior using TestScheduler?

c#

unit-testing

scheduler

reactive-programming

system.reactive