Class AsyncDelegateFilter<TContext>

Namespace

MassTransit.Middleware

Assembly

MassTransit.Abstractions.dll

public class AsyncDelegateFilter<TContext> : IFilter<TContext>, IProbeSite where TContext : class, PipeContext

Type Parameters

TContext

Inheritance

object

AsyncDelegateFilter<TContext>

Implements

IFilter<TContext>

IProbeSite

Inherited Members

object.GetType()

object.MemberwiseClone()

object.ToString()

object.Equals(object)

object.Equals(object, object)

object.ReferenceEquals(object, object)

object.GetHashCode()

Extension Methods

Pipe.ToPipe<T>(IFilter<T>)

Constructors

AsyncDelegateFilter(Func<TContext, Task>)

public AsyncDelegateFilter(Func<TContext, Task> callback)

Parameters

callback Func<TContext, Task>

Methods

Send(TContext, IPipe<TContext>)

Sends a context to a filter, such that it can be processed and then passed to the specified output pipe for further processing.

public Task Send(TContext context, IPipe<TContext> next)

Parameters

context TContext

The pipe context type

next IPipe<TContext>

The next pipe in the pipeline

Returns

Task

An awaitable Task