Class QueueEventSource<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 IMutableEventQueue<TEvent, TPoint, TPointDelta> instance.

public class QueueEventSource<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>>

QueueEventSource<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

QueueEventSource(IMutableEventQueue<TEvent, TPoint, TPointDelta>)

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

public QueueEventSource(IMutableEventQueue<TEvent, TPoint, TPointDelta> queue)

Parameters

queue IMutableEventQueue<TEvent, TPoint, TPointDelta>

Underlying queue.

Properties

Queue

Underlying queue.

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

Property Value

IEventQueue<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.