Class Connectable<T>

Namespace

MassTransit.Util

Assembly

MassTransit.Abstractions.dll

Maintains a collection of connections of the generic type

public class Connectable<T> where T : class

Type Parameters

T

The connectable type

Inheritance

object

Connectable<T>

Derived

ActivityConfigurationObservable

ConsumePipeSpecificationObservable

ConsumeTopologyConfigurationObservable

ConsumerConfigurationObservable

EndpointConfigurationObservable

HandlerConfigurationObservable

MessageTopologyConfigurationObservable

PublishPipeSpecificationObservable

PublishTopologyConfigurationObservable

SagaConfigurationObservable

SendPipeSpecificationObservable

SendTopologyConfigurationObservable

ActivityObservable

BusObservable

ConsumeObservable

FilterObservable

FilterObservable<TContext>

PublishObservable

ReceiveEndpointObservable

ReceiveObservable

ReceiveTransportObservable

RetryObservable

SendObservable

Inherited Members

object.GetType()

object.MemberwiseClone()

object.ToString()

object.Equals(object)

object.Equals(object, object)

object.ReferenceEquals(object, object)

object.GetHashCode()

Constructors

Connectable()

public Connectable()

Properties

Count

The number of connections

public int Count { get; }

Property Value

int

Methods

All(Func<T, bool>)

public bool All(Func<T, bool> callback)

Parameters

callback Func<T, bool>

Returns

bool

Connect(T)

Connect a connectable type

public ConnectHandle Connect(T connection)

Parameters

connection T

The connection to add

Returns

ConnectHandle

The connection handle

ForEach(Action<T>)

public void ForEach(Action<T> callback)

Parameters

callback Action<T>

ForEachAsync(Func<T, Task>)

Enumerate the connections invoking the callback for each connection

public Task ForEachAsync(Func<T, Task> callback)

Parameters

callback Func<T, Task>

The callback

Returns

Task

An awaitable Task for the operation