Class ReorderableQueueEventSource<TEvent, TPoint, TPointDelta>

Namespace

LfrlAnvil.Reactive.Queues

Assembly

LfrlAnvil.Reactive.Queues.dll

Represents a generic disposable event source that can be listened to based on an underlying IMutableReorderableEventQueue<TEvent, TPoint, TPointDelta> instance.

public class ReorderableQueueEventSource<TEvent, TPoint, TPointDelta> : EventSource<FromQueue<TEvent, TPoint, TPointDelta>>, IEventSource<FromQueue<TEvent, TPoint, TPointDelta>>, IEventStream<FromQueue<TEvent, TPoint, TPointDelta>>, IEventSource, IEventStream, IDisposable

Type Parameters

TEvent

Event type.

TPoint

Queue point type.

TPointDelta

Queue point delta type.

Inheritance

object

EventSource<FromQueue<TEvent, TPoint, TPointDelta>>

ReorderableQueueEventSource<TEvent, TPoint, TPointDelta>

Implements

IEventSource<FromQueue<TEvent, TPoint, TPointDelta>>

IEventStream<FromQueue<TEvent, TPoint, TPointDelta>>

IEventSource

IEventStream

IDisposable

Inherited Members

EventSource<FromQueue<TEvent, TPoint, TPointDelta>>.IsDisposed

EventSource<FromQueue<TEvent, TPoint, TPointDelta>>.Subscribers

EventSource<FromQueue<TEvent, TPoint, TPointDelta>>.HasSubscribers

EventSource<FromQueue<TEvent, TPoint, TPointDelta>>.Dispose()

EventSource<FromQueue<TEvent, TPoint, TPointDelta>>.Listen(IEventListener<FromQueue<TEvent, TPoint, TPointDelta>>)

EventSource<FromQueue<TEvent, TPoint, TPointDelta>>.Decorate<TNextEvent>(IEventListenerDecorator<FromQueue<TEvent, TPoint, TPointDelta>, TNextEvent>)

EventSource<FromQueue<TEvent, TPoint, TPointDelta>>.OnSubscriberAddedUnsafe(IEventSubscriber, IEventListener<FromQueue<TEvent, TPoint, TPointDelta>>)

EventSource<FromQueue<TEvent, TPoint, TPointDelta>>.OverrideListenerUnsafe(IEventSubscriber, IEventListener<FromQueue<TEvent, TPoint, TPointDelta>>)

EventSource<FromQueue<TEvent, TPoint, TPointDelta>>.OnSubscriberRegistered(IEventSubscriber, IEventListener<FromQueue<TEvent, TPoint, TPointDelta>>)

EventSource<FromQueue<TEvent, TPoint, TPointDelta>>.DisposeCore(out Chain<Exception>)

EventSource<FromQueue<TEvent, TPoint, TPointDelta>>.GetCurrentSubscribersUnsafe()

EventSource<FromQueue<TEvent, TPoint, TPointDelta>>.NotifyListeners(ArrayPoolToken<IEventSubscriber>, FromQueue<TEvent, TPoint, TPointDelta>)

EventSource<FromQueue<TEvent, TPoint, TPointDelta>>.TryNotifyListeners(FromQueue<TEvent, TPoint, TPointDelta>)

EventSource<FromQueue<TEvent, TPoint, TPointDelta>>.ThrowDisposedException()

EventSource<FromQueue<TEvent, TPoint, TPointDelta>>.AcquireLock()

EventSource<FromQueue<TEvent, TPoint, TPointDelta>>.IsDisposedUnsafe()

object.Equals(object)

object.Equals(object, object)

object.GetHashCode()

object.GetType()

object.MemberwiseClone()

object.ReferenceEquals(object, object)

object.ToString()

Constructors

ReorderableQueueEventSource(IMutableReorderableEventQueue<TEvent, TPoint, TPointDelta>)

Creates a new ReorderableQueueEventSource<TEvent, TPoint, TPointDelta> instance.

public ReorderableQueueEventSource(IMutableReorderableEventQueue<TEvent, TPoint, TPointDelta> queue)

Parameters

queue IMutableReorderableEventQueue<TEvent, TPoint, TPointDelta>

Underlying queue.

Properties

Queue

Underlying queue.

public IReorderableEventQueue<TEvent, TPoint, TPointDelta> Queue { get; }

Property Value

IReorderableEventQueue<TEvent, TPoint, TPointDelta>

Methods

Dispose()

Performs application-defined tasks associated with freeing, releasing, or resetting unmanaged resources.

public override void Dispose()

Move(TPointDelta)

Moves the CurrentPoint of the Queue forward and emits events for all dequeued events.

public void Move(TPointDelta delta)

Parameters

delta TPointDelta

Point delta to move the CurrentPoint forward by.