Struct InMemoryChannelTransport 

pub struct InMemoryChannelTransport { /* private fields */ }

In-memory transport using channels.

This is the default transport for local testing where all roles run in the same process.

Implementations

impl InMemoryChannelTransport

pub fn new(role: RoleName) -> Self

Create a new in-memory transport for a role.

pub async fn connect(&self, other: &InMemoryChannelTransport)

Connect this transport to another role’s transport.

pub fn role(&self) -> &RoleName

Get the role name.

Trait Implementations

impl DocumentedTransportContract for InMemoryChannelTransport

fn contract_profile() -> TransportContractProfile

impl Transport for InMemoryChannelTransport

fn send<'life0, 'life1, 'async_trait>( &'life0 self, to_role: &'life1 RoleName, message: Vec<u8>, ) -> Pin<Box<dyn Future<Output = TransportResult<()>> + Send + 'async_trait>>

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

Send a message to a specific role.

fn recv<'life0, 'life1, 'async_trait>( &'life0 self, from_role: &'life1 RoleName, ) -> Pin<Box<dyn Future<Output = TransportResult<Vec<u8>>> + Send + 'async_trait>>

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

Receive a message from a specific role.

fn is_connected(&self, _role: &RoleName) -> bool

Check if the transport is connected to a role.

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

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

Close the transport connection.