Class AbstractTransportAdapter

An adapter that wraps a transport and provides interception capabilities

Inheritance

object

Transport

AbstractTransportAdapter

ActorTransportAdapter

FailureInjectorTransportAdapter

Inherited Members

Transport.Config

Transport.System

Transport.ManagementCommand(object)

object.Equals(object)

object.Equals(object, object)

object.GetHashCode()

object.GetType()

object.MemberwiseClone()

object.ReferenceEquals(object, object)

object.ToString()

Namespace: Akka.Remote.Transport

Assembly: Akka.Remote.dll

Syntax

public abstract class AbstractTransportAdapter : Transport

Constructors

| Edit this page View Source

AbstractTransportAdapter(Transport)

TBD

Declaration

protected AbstractTransportAdapter(Transport wrappedTransport)

Parameters

Type	Name	Description
Transport	wrappedTransport	TBD

Fields

| Edit this page View Source

WrappedTransport

TBD

Declaration

protected Transport WrappedTransport

Field Value

Type	Description
Transport

Properties

| Edit this page View Source

MaximumPayloadBytes

TBD

Declaration

public override long MaximumPayloadBytes { get; }

Property Value

Type	Description
long

Overrides

Transport.MaximumPayloadBytes

| Edit this page View Source

SchemeAugmenter

TBD

Declaration

protected abstract SchemeAugmenter SchemeAugmenter { get; }

Property Value

Type	Description
SchemeAugmenter

| Edit this page View Source

SchemeIdentifier

TBD

Declaration

public override string SchemeIdentifier { get; }

Property Value

Type	Description
string

Overrides

Transport.SchemeIdentifier

Methods

| Edit this page View Source

Associate(Address)

TBD

Declaration

public override Task<AssociationHandle> Associate(Address remoteAddress)

Parameters

Type	Name	Description
Address	remoteAddress	TBD

Returns

Type	Description
Task<AssociationHandle>	TBD

Overrides

Transport.Associate(Address)

| Edit this page View Source

InterceptAssociate(Address, TaskCompletionSource<AssociationHandle>)

TBD

Declaration

protected abstract void InterceptAssociate(Address remoteAddress, TaskCompletionSource<AssociationHandle> statusPromise)

Parameters

Type	Name	Description
Address	remoteAddress	TBD
TaskCompletionSource<AssociationHandle>	statusPromise	TBD

| Edit this page View Source

InterceptListen(Address, Task<IAssociationEventListener>)

TBD

Declaration

protected abstract Task<IAssociationEventListener> InterceptListen(Address listenAddress, Task<IAssociationEventListener> listenerTask)

Parameters

Type	Name	Description
Address	listenAddress	TBD
Task<IAssociationEventListener>	listenerTask	TBD

Returns

Type	Description
Task<IAssociationEventListener>	TBD

| Edit this page View Source

IsResponsibleFor(Address)

TBD

Declaration

public override bool IsResponsibleFor(Address remote)

Parameters

Type	Name	Description
Address	remote	TBD

Returns

Type	Description
bool	TBD

Overrides

Transport.IsResponsibleFor(Address)

| Edit this page View Source

Listen()

TBD

Declaration

public override Task<(Address, TaskCompletionSource<IAssociationEventListener>)> Listen()

Returns

Type	Description
Task<(Address, TaskCompletionSource<IAssociationEventListener>)>	TBD

Overrides

Transport.Listen()

| Edit this page View Source

Shutdown()

TBD

Declaration

public override Task<bool> Shutdown()

Returns

Type	Description
Task<bool>	TBD

Overrides

Transport.Shutdown()

Extension Methods

ObjectExtensions.IsDefaultForType<T>(T)

ObjectExtensions.AsOption<T>(T)

Extensions.AsInstanceOf<T>(object)