Struct InMemoryTransport 

pub struct InMemoryTransport { /* private fields */ }

Shared registry for in-memory mem:// endpoints.

Implementations

impl InMemoryTransport

pub fn new() -> Self

Create an empty in-memory transport fabric.

pub fn with_buffer(self, buffer: usize) -> Self

Channel buffer depth for new stream pairs.

Trait Implementations

impl Clone for InMemoryTransport

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Default for InMemoryTransport

fn default() -> Self

Returns the “default value” for a type.

impl MeshTransport for InMemoryTransport

fn name(&self) -> &str

Human-readable transport name (e.g., “quic”, “websocket”, “tcp”).

fn listen<'life0, 'life1, 'async_trait>( &'life0 self, addr: &'life1 str, ) -> Pin<Box<dyn Future<Output = Result<Box<dyn TransportListener>, MeshError>> + Send + 'async_trait>>

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

Start listening for incoming connections on the given address.

fn connect<'life0, 'life1, 'async_trait>( &'life0 self, addr: &'life1 str, ) -> Pin<Box<dyn Future<Output = Result<Box<dyn MeshStream>, MeshError>> + Send + 'async_trait>>

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

Connect to a remote peer at the given address.

fn supports(&self, addr: &str) -> bool

Check if this transport supports the given address scheme.