Class SplitFilter<TInput, TSplit>

Namespace

MassTransit.Middleware

Assembly

MassTransit.Abstractions.dll

public class SplitFilter<TInput, TSplit> : IFilter<TInput>, IProbeSite where TInput : class, PipeContext where TSplit : class, PipeContext

Type Parameters

TInput

TSplit

Inheritance

object

SplitFilter<TInput, TSplit>

Implements

IFilter<TInput>

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

SplitFilter(IFilter<TSplit>, MergeFilterContextProvider<TInput, TSplit>, FilterContextProvider<TSplit, TInput>)

public SplitFilter(IFilter<TSplit> split, MergeFilterContextProvider<TInput, TSplit> contextProvider, FilterContextProvider<TSplit, TInput> inputContextProvider)

Parameters

split IFilter<TSplit>

contextProvider MergeFilterContextProvider<TInput, TSplit>

inputContextProvider FilterContextProvider<TSplit, TInput>

Methods

Probe(ProbeContext)

public void Probe(ProbeContext context)

Parameters

context ProbeContext

Send(TInput, IPipe<TInput>)

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(TInput context, IPipe<TInput> next)

Parameters

context TInput

The pipe context type

next IPipe<TInput>

The next pipe in the pipeline

Returns

Task

An awaitable Task