Struct MemoryTransport 

pub struct MemoryTransport { /* private fields */ }

In-memory transport for testing and local communication that extends FramedTransport

Implementations

impl MemoryTransport

pub fn new() -> (Self, Self)

Create new memory transports for testing

pub fn pair() -> (Self, Self)

Backward-compatible alias used by tests and examples.

Trait Implementations

impl FramedTransport for MemoryTransport

fn base_send<'life0, 'life1, 'async_trait>( &'life0 mut self, data: &'life1 [u8], ) -> Pin<Box<dyn Future<Output = ErpcResult<()>> + Send + 'async_trait>>

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

Send raw data without framing (implemented by concrete transports)

fn base_receive<'life0, 'async_trait>( &'life0 mut self, length: usize, ) -> Pin<Box<dyn Future<Output = ErpcResult<Vec<u8>>> + Send + 'async_trait>>

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

Receive exact number of raw bytes without framing (implemented by concrete transports)

fn is_connected(&self) -> bool

Check if the transport is connected (implemented by concrete transports)

fn close<'life0, 'async_trait>( &'life0 mut self, ) -> Pin<Box<dyn Future<Output = ErpcResult<()>> + Send + 'async_trait>>

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

Close the transport (implemented by concrete transports)

fn set_timeout(&mut self, timeout: Duration)

Set timeout for operations (implemented by concrete transports)