Class ObservableMessagesReturnValueHandler

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

Inheritance

object

ObservableMessagesReturnValueHandler

Implements

IReturnValueHandler

Inherited Members

object.Equals(object)

object.Equals(object, object)

object.GetHashCode()

object.GetType()

object.MemberwiseClone()

object.ReferenceEquals(object, object)

object.ToString()

Namespace: Silverback.Messaging.Subscribers.ReturnValueHandlers

Assembly: Silverback.Core.Rx.dll

Syntax

public class ObservableMessagesReturnValueHandler : IReturnValueHandler

Constructors

ObservableMessagesReturnValueHandler(IPublisher, IBusOptions)

Initializes a new instance of the ObservableMessagesReturnValueHandler class.

Declaration

public ObservableMessagesReturnValueHandler(IPublisher publisher, IBusOptions busOptions)

Parameters

Type	Name	Description
IPublisher	publisher	The IPublisher to be used to publish the messages.
IBusOptions	busOptions	The IBusOptions 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.

Declaration

public bool CanHandle(object returnValue)

Parameters

Type	Name	Description
object	returnValue	The value to be handled.

Returns

Type	Description
bool	A boolean value indicating whether the value can be handled.

Handle(object)

Handles the specified return value.

Declaration

public void Handle(object returnValue)

Parameters

Type	Name	Description
object	returnValue	The value to be handled.

HandleAsync(object)

Handles the specified return value.

Declaration

public Task HandleAsync(object returnValue)

Parameters

Type	Name	Description
object	returnValue	The value to be handled.

Returns

Type	Description
Task	A Task representing the asynchronous operation.

Implements

IReturnValueHandler