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

| Edit this page View Source

TestTransport(ActorSystem, Config)

TBD

Declaration

public TestTransport(ActorSystem system, Config conf)

Parameters

Type	Name	Description
ActorSystem	system	TBD
Config	conf	TBD

| Edit this page View Source

TestTransport(Address, AssociationRegistry, long, string)

TBD

Declaration

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

Parameters

Type	Name	Description
Address	localAddress	TBD
AssociationRegistry	registry	TBD
long	maximumPayloadBytes	TBD
string	schemeIdentifier	TBD

Fields

| Edit this page View Source

AssociateBehavior

Declaration

public readonly SwitchableLoggedBehavior<Address, AssociationHandle> AssociateBehavior

Field Value

Type	Description
SwitchableLoggedBehavior<Address, AssociationHandle>

| Edit this page View Source

DisassociateBehavior

Declaration

public readonly SwitchableLoggedBehavior<TestAssociationHandle, bool> DisassociateBehavior

Field Value

Type	Description
SwitchableLoggedBehavior<TestAssociationHandle, bool>

| Edit this page View Source

ListenBehavior

Declaration

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

Field Value

Type	Description
SwitchableLoggedBehavior<bool, (Address, TaskCompletionSource<IAssociationEventListener>)>

| Edit this page View Source

LocalAddress

Declaration

public readonly Address LocalAddress

Field Value

Type	Description
Address

| Edit this page View Source

ShutdownBehavior

Declaration

public readonly SwitchableLoggedBehavior<bool, bool> ShutdownBehavior

Field Value

Type	Description
SwitchableLoggedBehavior<bool, bool>

| Edit this page View Source

WriteBehavior

Declaration

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

Field Value

Type	Description
SwitchableLoggedBehavior<(TestAssociationHandle, ByteString), bool>

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

DefaultDisassociate(TestAssociationHandle)

TBD

Declaration

public Task<bool> DefaultDisassociate(TestAssociationHandle handle)

Parameters

Type	Name	Description
TestAssociationHandle	handle	TBD

Returns

Type	Description
Task<bool>	TBD

| Edit this page View Source

DefaultListen()

TBD

Declaration

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

Returns

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

| Edit this page View Source

Disassociate(TestAssociationHandle)

TBD

Declaration

public Task Disassociate(TestAssociationHandle handle)

Parameters

Type	Name	Description
TestAssociationHandle	handle	TBD

Returns

Type	Description
Task	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()

| Edit this page View Source

Write(TestAssociationHandle, ByteString)

TBD

Declaration

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

Parameters

Type	Name	Description
TestAssociationHandle	handle	TBD
ByteString	payload	TBD

Returns

Type	Description
Task<bool>	TBD

Extension Methods

ObjectExtensions.IsDefaultForType<T>(T)

ObjectExtensions.AsOption<T>(T)

Extensions.AsInstanceOf<T>(object)