EventBus

Namespace: SnowBank.Messaging.Events · class

Implements: IEventBus, IAsyncDisposable

Constructors

EventBus

EventBus(IEnumerable<IEventSink> sinks, IClock clock)

Properties

Clock

IClock Clock { get; }

Sinks

IEventSink[] Sinks { get; }

Methods

Create

static EventBus Create(IEventSink sink, IClock clock = null)

CreateInMemory

static EventBus CreateInMemory(IEventFilter filter = null, IClock clock = null)

Dispatch

void Dispatch(IEvent evt)

void Dispatch(ReadOnlyMemory<IEvent> batch)

DisposeAsync

ValueTask DisposeAsync()

DrainAsync

Task DrainAsync(CancellationToken ct)

GetSinks

List<IEventSink> GetSinks()

Now

Instant Now()