Class Pipe

Namespace

MassTransit

Assembly

MassTransit.Abstractions.dll

public static class Pipe

Inheritance

object

Pipe

Inherited Members

object.GetType()

object.MemberwiseClone()

object.ToString()

object.Equals(object)

object.Equals(object, object)

object.ReferenceEquals(object, object)

object.GetHashCode()

Methods

AddCallback<T>(IPipe<T>, Action<T>)

Constructs a simple pipe that executes the specified action

public static IPipe<T> AddCallback<T>(this IPipe<T> pipe, Action<T> action) where T : class, PipeContext

Parameters

pipe IPipe<T>

action Action<T>

The method to execute

Returns

IPipe<T>

The constructed pipe

Type Parameters

T

The pipe context type

Empty<T>()

Returns an empty pipe of the specified context type

public static IPipe<T> Empty<T>() where T : class, PipeContext

Returns

IPipe<T>

Type Parameters

T

The context type

ExecuteAsync<T>(Func<T, Task>)

Constructs a simple pipe that executes the specified action

public static IPipe<T> ExecuteAsync<T>(Func<T, Task> action) where T : class, PipeContext

Parameters

action Func<T, Task>

The method to execute

Returns

IPipe<T>

The constructed pipe

Type Parameters

T

The pipe context type

Execute<T>(Action<T>)

Constructs a simple pipe that executes the specified action

public static IPipe<T> Execute<T>(Action<T> action) where T : class, PipeContext

Parameters

action Action<T>

The method to execute

Returns

IPipe<T>

The constructed pipe

Type Parameters

T

The pipe context type

New<T>(Action<IPipeConfigurator<T>>)

Create a new pipe using the pipe configurator to add filters, etc.

public static IPipe<T> New<T>(Action<IPipeConfigurator<T>> callback) where T : class, PipeContext

Parameters

callback Action<IPipeConfigurator<T>>

The configuration callback

Returns

IPipe<T>

An initialized pipe ready for use

Type Parameters

T

The pipe context type

New<T>(Action<IPipeConfigurator<T>>, bool)

Create a new pipe using the pipe configurator to add filters, etc.

public static IPipe<T> New<T>(Action<IPipeConfigurator<T>> callback, bool validate) where T : class, PipeContext

Parameters

callback Action<IPipeConfigurator<T>>

The configuration callback

validate bool

True if the pipe should be validated

Returns

IPipe<T>

An initialized pipe ready for use

Type Parameters

T

The pipe context type

ToPipe<T>(IFilter<T>)

Returns a pipe for the filter

public static IPipe<T> ToPipe<T>(this IFilter<T> filter) where T : class, PipeContext

Parameters

filter IFilter<T>

Returns

IPipe<T>

Type Parameters

T

Exceptions

ArgumentNullException