Struct TestTransport 

pub struct TestTransport {
    pub local_address: Address,
    pub registry: Arc<TestRegistry>,
    /* private fields */
}

A TestTransport lets multiple Address participants exchange AkkaPdu frames without going through the network.

Fields

local_address: Address

registry: Arc<TestRegistry>

Implementations

impl TestTransport

pub fn new(address: Address, registry: Arc<TestRegistry>) -> Self

Trait Implementations

impl Clone for TestTransport

fn clone(&self) -> TestTransport

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Transport for TestTransport

fn listen<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<Address, TransportError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Bind a listener and return the local Address.

fn associate<'life0, 'life1, 'async_trait>( &'life0 self, target: &'life1 Address, ) -> Pin<Box<dyn Future<Output = Result<(), TransportError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Open (or reuse) an outbound association to target.

fn send<'life0, 'life1, 'async_trait>( &'life0 self, target: &'life1 Address, pdu: AkkaPdu, ) -> Pin<Box<dyn Future<Output = Result<(), TransportError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Send a single PDU to the peer at target. Implementations are expected to associate lazily if needed.

fn inbound(&self) -> UnboundedReceiver<InboundFrame>

Take ownership of the inbound stream. Calling more than once returns an empty channel.

fn disassociate<'life0, 'life1, 'async_trait>( &'life0 self, _target: &'life1 Address, ) -> Pin<Box<dyn Future<Output = Result<(), TransportError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Drop a specific association (used by quarantine).

fn shutdown<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<(), TransportError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Stop listening and close all associations.