Class TestTransport

Transport implementation used for testing. The TestTransport is basically shared memory between actor systems. It can be programmed to emulate different failure modes of a Transport implementation. TestTransport keeps a log of the activities it was requested to do. This class is not optimized for performance and MUST not be used in production systems.

Inheritance

Object

Transport

TestTransport

Inherited Members

Transport.Config

Transport.System

Transport.SchemeIdentifier

Transport.MaximumPayloadBytes

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 class TestTransport : Transport

Constructors

| Improve this Doc View Source

TestTransport(ActorSystem, Config)

TBD

Declaration

public TestTransport(ActorSystem system, Config conf)

Parameters

Type	Name	Description
ActorSystem	system	TBD
Config	conf	TBD

| Improve this Doc View Source

TestTransport(Address, AssociationRegistry, Int64, String)

TBD

Declaration

public TestTransport(Address localAddress, AssociationRegistry registry, long maximumPayloadBytes = 32000L, string schemeIdentifier = "test")

Parameters

Type	Name	Description
Address	localAddress	TBD
AssociationRegistry	registry	TBD
Int64	maximumPayloadBytes	TBD
String	schemeIdentifier	TBD

Fields

| Improve this Doc View Source

AssociateBehavior

Declaration

public readonly SwitchableLoggedBehavior<Address, AssociationHandle> AssociateBehavior

Field Value

Type	Description
SwitchableLoggedBehavior<Address, AssociationHandle>

| Improve this Doc View Source

DisassociateBehavior

Declaration

public readonly SwitchableLoggedBehavior<TestAssociationHandle, bool> DisassociateBehavior

Field Value

Type	Description
SwitchableLoggedBehavior<TestAssociationHandle, Boolean>

| Improve this Doc View Source

ListenBehavior

Declaration

public readonly SwitchableLoggedBehavior<bool, (Address, TaskCompletionSource<IAssociationEventListener>)> ListenBehavior

Field Value

Type	Description
SwitchableLoggedBehavior<Boolean, System.ValueTuple<Address, TaskCompletionSource<IAssociationEventListener>>>

| Improve this Doc View Source

LocalAddress

Declaration

public readonly Address LocalAddress

Field Value

Type	Description
Address

| Improve this Doc View Source

ShutdownBehavior

Declaration

public readonly SwitchableLoggedBehavior<bool, bool> ShutdownBehavior

Field Value

Type	Description
SwitchableLoggedBehavior<Boolean, Boolean>

| Improve this Doc View Source

WriteBehavior

Declaration

public readonly SwitchableLoggedBehavior<(TestAssociationHandle, ByteString), bool> WriteBehavior

Field Value

Type	Description
SwitchableLoggedBehavior<System.ValueTuple<TestAssociationHandle, Google.Protobuf.ByteString>, Boolean>

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

DefaultDisassociate(TestAssociationHandle)

TBD

Declaration

public Task<bool> DefaultDisassociate(TestAssociationHandle handle)

Parameters

Type	Name	Description
TestAssociationHandle	handle	TBD

Returns

Type	Description
Task<Boolean>	TBD

| Improve this Doc View Source

DefaultListen()

TBD

Declaration

public Task<(Address, TaskCompletionSource<IAssociationEventListener>)> DefaultListen()

Returns

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

| Improve this Doc View Source

Disassociate(TestAssociationHandle)

TBD

Declaration

public Task Disassociate(TestAssociationHandle handle)

Parameters

Type	Name	Description
TestAssociationHandle	handle	TBD

Returns

Type	Description
Task	TBD

| Improve this Doc View Source

IsResponsibleFor(Address)

Declaration

public override bool IsResponsibleFor(Address remote)

Parameters

Type	Name	Description
Address	remote

Returns

Type	Description
Boolean

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()

| Improve this Doc View Source

Write(TestAssociationHandle, ByteString)

TBD

Declaration

public Task<bool> Write(TestAssociationHandle handle, ByteString payload)

Parameters

Type	Name	Description
TestAssociationHandle	handle	TBD
Google.Protobuf.ByteString	payload	TBD

Returns

Type	Description
Task<Boolean>	TBD

Extension Methods

ObjectExtensions.IsDefaultForType<T>(T)

ObjectExtensions.AsOption<T>(T)

Extensions.AsInstanceOf<T>(Object)