Class MergePipe<TInput, TSplit>

Namespace

MassTransit.Middleware

Assembly

MassTransit.Abstractions.dll

public class MergePipe<TInput, TSplit> : IPipe<TSplit>, IProbeSite where TInput : class, PipeContext where TSplit : class, PipeContext

Type Parameters

TInput

TSplit

Inheritance

object

MergePipe<TInput, TSplit>

Implements

IPipe<TSplit>

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.AddCallback<T>(IPipe<T>, Action<T>)

PipeExtensions.IsEmpty<T>(IPipe<T>?)

PipeExtensions.IsNotEmpty<T>(IPipe<T>?)

Constructors

MergePipe(IPipe<TInput>, TInput, MergeFilterContextProvider<TInput, TSplit>)

public MergePipe(IPipe<TInput> next, TInput input, MergeFilterContextProvider<TInput, TSplit> contextProvider)

Parameters

next IPipe<TInput>

input TInput

contextProvider MergeFilterContextProvider<TInput, TSplit>

Methods

Probe(ProbeContext)

public void Probe(ProbeContext context)

Parameters

context ProbeContext

Send(TSplit)

The base primitive, Send delivers the pipe context of T to the pipe.

public Task Send(TSplit context)

Parameters

context TSplit

The pipe context of type T

Returns

Task

A task which is completed once the pipe has processed the context