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

| Improve this Doc View Source

AbstractTransportAdapter(Transport)

TBD

Declaration

protected AbstractTransportAdapter(Transport wrappedTransport)

Parameters

Type	Name	Description
Transport	wrappedTransport	TBD

Fields

| Improve this Doc View Source

WrappedTransport

TBD

Declaration

protected Transport WrappedTransport

Field Value

Type	Description
Transport

Properties

| Improve this Doc View Source

MaximumPayloadBytes

TBD

Declaration

public override long MaximumPayloadBytes { get; }

Property Value

Type	Description
Int64

Overrides

Transport.MaximumPayloadBytes

| Improve this Doc View Source

SchemeAugmenter

TBD

Declaration

protected abstract SchemeAugmenter SchemeAugmenter { get; }

Property Value

Type	Description
SchemeAugmenter

| Improve this Doc View Source

SchemeIdentifier

TBD

Declaration

public override string SchemeIdentifier { get; }

Property Value

Type	Description
String

Overrides

Transport.SchemeIdentifier

Methods

| Improve this Doc 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)

| Improve this Doc 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

| Improve this Doc 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

| Improve this Doc View Source

IsResponsibleFor(Address)

TBD

Declaration

public override bool IsResponsibleFor(Address remote)

Parameters

Type	Name	Description
Address	remote	TBD

Returns

Type	Description
Boolean	TBD

Overrides

Transport.IsResponsibleFor(Address)

| Improve this Doc View Source

Listen()

TBD

Declaration

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

Returns

Type	Description
Task<System.ValueTuple<Address, TaskCompletionSource<IAssociationEventListener>>>	TBD

Overrides

Transport.Listen()

| Improve this Doc View Source

Shutdown()

TBD

Declaration

public override Task<bool> Shutdown()

Returns

Type	Description
Task<Boolean>	TBD

Overrides

Transport.Shutdown()

Extension Methods

ObjectExtensions.IsDefaultForType<T>(T)

ObjectExtensions.AsOption<T>(T)

Extensions.AsInstanceOf<T>(Object)