Class AggregateMessageSink

An implementation of IMessageSink which dispatches messages to one or more individual message sinks.

public class AggregateMessageSink : IMessageSink, IAsyncDisposable

Inherited Members: object.Equals(object)

object.Equals(object, object)

object.GetHashCode()

object.GetType()

object.MemberwiseClone()

object.ReferenceEquals(object, object)

object.ToString()

Properties

The list of event dispatchers that are registered with the system.

protected List<IMessageSink> AggregatedSinks { get; }

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

public virtual ValueTask DisposeAsync()

Gets a dispatcher, optionally creating and registering it if it doesn't exist.

protected TDispatcher GetOrCreateAggregatedSink<TDispatcher>(ref TDispatcher? value) where TDispatcher : class, IMessageSink, new()

Reports the presence of a message on the message bus. This method should never throw exceptions.

public virtual bool OnMessage(IMessageSinkMessage message)