namespace System.Reactive.Concurrency { public class SchedulerQueue<[System.Runtime.CompilerServices.Nullable(0)] TAbsolute> where TAbsolute : IComparable<TAbsolute> { public int Count { get; } public SchedulerQueue(); public SchedulerQueue(int capacity); public void Enqueue(ScheduledItem<TAbsolute> scheduledItem); public bool Remove(ScheduledItem<TAbsolute> scheduledItem); public ScheduledItem<TAbsolute> Dequeue(); public ScheduledItem<TAbsolute> Peek(); } } namespace System.Reactive.Linq.ObservableImpl { }