Class ForeachAwaitContinueOnFailurePublisher

Namespace

Caesar.NotificationPublishers

Assembly

Caesar.dll

Awaits handlers one after another like ForeachAwaitPublisher, but keeps going after a failing handler and throws an AggregateException at the end if any handler failed. Useful when every subscriber must get the event even if one of them is broken.

public sealed class ForeachAwaitContinueOnFailurePublisher : INotificationPublisher

Inheritance

object

ForeachAwaitContinueOnFailurePublisher

Implements

INotificationPublisher

Inherited Members

object.GetType()

object.ToString()

object.Equals(object)

object.Equals(object, object)

object.ReferenceEquals(object, object)

object.GetHashCode()

Constructors

ForeachAwaitContinueOnFailurePublisher()

public ForeachAwaitContinueOnFailurePublisher()

Methods

Publish(IEnumerable<NotificationHandlerExecutor>, INotification, CancellationToken)

Invokes the handler executors for notification.

public Task Publish(IEnumerable<NotificationHandlerExecutor> handlerExecutors, INotification notification, CancellationToken cancellationToken)

Parameters

handlerExecutors IEnumerable<NotificationHandlerExecutor>

One executor per resolved handler, in registration order.

notification INotification

The notification being published.

cancellationToken CancellationToken

Cancellation token.

Returns

Task