AsyncEventQueue

Wrapper for event queue that allows to iterate events asynchronously.

Methods

Wraps exising event queue into async event queue. It's user responsibility to provide valid event queue.

Params

eventQueue

IEventQueue

Event queue to wrap

AsyncEventQueue(
IEventQueue eventQueue
)

Stops and disposes event queue.

async ValueTask DisposeAsync()

Returns

async ValueTask ·

Iterates events until eiter event queue breaks or cancellation token is cancelled.

Params

token

CancellationToken

async IAsyncEnumerable<Event> WaitEventsAsync(
[EnumeratorCancellation] CancellationToken token = default
)

Returns

async IAsyncEnumerable<Event> · Stream of incoming events.