Wie Timeout-Verhalten mit TestScheduler zu erreichen?

Question

Ich habe die folgende Hilfsmethode erstellt mit Test Observablen zu unterstützen:

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); 
    } 

Dinge groß arbeiten, solange ich kein Timeout erwarten. Für Testfälle, bei denen ich ein Timeout erwarte, erreicht diese Methode niemals die OnException-Methode. Was ist der richtige Weg, um dies mit TestScheduler zu erreichen?

Ich sollte auch beachten, dass das Timeout ein Soft-Timeout ist, was bedeutet, dass, wenn das Observable nicht innerhalb der zugewiesenen Zeit abgeschlossen wurde, es nie abgeschlossen wird - aber es gibt kein entsprechendes Timeout innerhalb der Observable selbst definiert.

Answer 1

Sie müssen die TestScheduler zu Timeout mit this overload

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