Class PublishSendPipeAdapter<T>

Namespace

MassTransit.Transports

Assembly

MassTransit.Abstractions.dll

public class PublishSendPipeAdapter<T> : IPipe<SendContext<T>>, IProbeSite where T : class

Type Parameters

T

Inheritance

object

PublishSendPipeAdapter<T>

Implements

IPipe<SendContext<T>>

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

PublishSendPipeAdapter(IPipe<PublishContext<T>>)

public PublishSendPipeAdapter(IPipe<PublishContext<T>> pipe)

Parameters

pipe IPipe<PublishContext<T>>

Methods

Send(SendContext<T>)

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

public Task Send(SendContext<T> context)

Parameters

context SendContext<T>

The pipe context of type T

Returns

Task

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