RxTimeout.cs

[Fact]
public void timeout()
{
    var observable = Observable.Never<decimal>();
    int timesRun = 0;
    int timeouts = 0;
    observable.Subscribe(x => timesRun++);

    var testScheduler = new TestScheduler();
    observable.Timeout(TimeSpan.FromSeconds(1), testScheduler).Subscribe(x => timesRun++,
    e =>
    {
        timeouts++;
    });

    Assert.Equal(0, timesRun);
    testScheduler.AdvanceBy(TimeSpan.FromSeconds(1).Ticks - 1);
    Assert.Equal(0, timeouts);
    testScheduler.AdvanceBy(1);
    //testScheduler.Start();
    Assert.Equal(1, timeouts);
}