IScheduledObserver<T> interface IScheduledObserver<T> : IObserver<T>, IDisposable Documentation Code void EnsureActive() void EnsureActive(int count)