Class AsyncEnumerableMessagesReturnValueHandler

Namespace

Silverback.Messaging.Subscribers.ReturnValueHandlers

Assembly

Silverback.Core.dll

Handles the returned IAsyncEnumerable<T> republishing all the messages.

public class AsyncEnumerableMessagesReturnValueHandler : IReturnValueHandler

Inheritance

object

AsyncEnumerableMessagesReturnValueHandler

Implements

IReturnValueHandler

Inherited Members

object.GetType()

object.MemberwiseClone()

object.ToString()

object.Equals(object)

object.Equals(object, object)

object.ReferenceEquals(object, object)

object.GetHashCode()

Constructors

AsyncEnumerableMessagesReturnValueHandler(BusOptions)

Initializes a new instance of the AsyncEnumerableMessagesReturnValueHandler class.

public AsyncEnumerableMessagesReturnValueHandler(BusOptions busOptions)

Parameters

busOptions BusOptions

The BusOptions that specify which message types have to be handled.

Methods

CanHandle(object)

Returns a boolean value indicating whether this handler can handle the specified value.

public bool CanHandle(object returnValue)

Parameters

returnValue object

The value to be handled.

Returns

bool

A boolean value indicating whether the value can be handled.

Handle(IPublisher, object)

Handles the specified return value.

public void Handle(IPublisher publisher, object returnValue)

Parameters

publisher IPublisher

The IPublisher that published the message.

returnValue object

The value to be handled.

HandleAsync(IPublisher, object)

Handles the specified return value.

public ValueTask HandleAsync(IPublisher publisher, object returnValue)

Parameters

publisher IPublisher

The IPublisher that published the message.

returnValue object

The value to be handled.

Returns

ValueTask

A ValueTask representing the asynchronous operation.