System.Reactive.Concurrency.SchedulerQueue<TAbsolute>

SchedulerQueue<TAbsolute>

public class SchedulerQueue<TAbsolute> where TAbsolute : IComparable<TAbsolute>

Efficient scheduler queue that maintains scheduled items sorted by absolute time.

public int Count { get; }

Gets the number of scheduled items in the scheduler queue.

Creates a new scheduler queue with a default initial capacity.

public SchedulerQueue(int capacity)

Creates a new scheduler queue with the specified initial capacity.

public ScheduledItem<TAbsolute> Dequeue()

Dequeues the next work item from the scheduler queue.

public void Enqueue(ScheduledItem<TAbsolute> scheduledItem)

Enqueues the specified work item to be scheduled.

public ScheduledItem<TAbsolute> Peek()

Peeks the next work item in the scheduler queue.

public bool Remove(ScheduledItem<TAbsolute> scheduledItem)

Removes the specified work item from the scheduler queue.