Class FilterObservable

Namespace

MassTransit.Observables

Assembly

MassTransit.Abstractions.dll

public class FilterObservable : Connectable<IFilterObserver>, IFilterObserver

Inheritance

object

Connectable<IFilterObserver>

FilterObservable

Implements

IFilterObserver

Inherited Members

Connectable<IFilterObserver>.Connect(IFilterObserver)

Connectable<IFilterObserver>.ForEachAsync(Func<IFilterObserver, Task>)

Connectable<IFilterObserver>.ForEach(Action<IFilterObserver>)

Connectable<IFilterObserver>.All(Func<IFilterObserver, bool>)

Connectable<IFilterObserver>.Count

object.GetType()

object.MemberwiseClone()

object.ToString()

object.Equals(object)

object.Equals(object, object)

object.ReferenceEquals(object, object)

object.GetHashCode()

Constructors

FilterObservable()

public FilterObservable()

Methods

PostSend<T>(T)

Called after the message has been dispatched to all consumers - note that in the case of an exception this method is not called, and the DispatchFaulted method is called instead

public Task PostSend<T>(T context) where T : class, PipeContext

Parameters

context T

Returns

Task

Type Parameters

T

PreSend<T>(T)

Called before a message is dispatched to any consumers

public Task PreSend<T>(T context) where T : class, PipeContext

Parameters

context T

The consume context

Returns

Task

Type Parameters

T

SendFault<T>(T, Exception)

Called after the message has been dispatched to all consumers when one or more exceptions have occurred

public Task SendFault<T>(T context, Exception exception) where T : class, PipeContext

Parameters

context T

exception Exception

Returns

Task

Type Parameters

T