Class ObservableMessagesReturnValueHandler

Namespace

Silverback.Messaging.Subscribers.ReturnValueHandlers

Assembly

Silverback.Core.Rx.dll

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

public class ObservableMessagesReturnValueHandler : IReturnValueHandler

Inheritance

object

ObservableMessagesReturnValueHandler

Implements

IReturnValueHandler

Inherited Members

object.GetType()

object.MemberwiseClone()

object.ToString()

object.Equals(object)

object.Equals(object, object)

object.ReferenceEquals(object, object)

object.GetHashCode()

Constructors

ObservableMessagesReturnValueHandler(BusOptions)

Initializes a new instance of the ObservableMessagesReturnValueHandler class.

public ObservableMessagesReturnValueHandler(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.