Scheduler Testing

gistfile1.cs

Console.ReadLine();

var sched = Scheduler.TaskPool;

var count = Observable
    .Return(new Unit(), sched)
    .Repeat()
    // Use NewThread to avoid bias on the cutoff.
    .TakeUntil(Observable.Timer(TimeSpan.FromSeconds(5), Scheduler.NewThread))
    .Count()
    .Single();

Console.WriteLine(count);
Console.ReadLine();