Struct InMemoryTransport 

pub struct InMemoryTransport { /* private fields */ }

In-memory transport for testing.

Implementations

impl InMemoryTransport

pub fn new_network(nodes: &[NodeId]) -> HashMap<NodeId, Self>

Create a new in-memory transport network.

pub fn new(node_id: NodeId) -> Self

Create a single transport (for testing).

Trait Implementations

impl Transport for InMemoryTransport

fn send(&self, message: Message) -> Result<(), TransportError>

Send a message to a node.

fn recv(&self) -> Result<Message, TransportError>

Receive a message (blocking).

fn try_recv(&self) -> Option<Message>

Try to receive a message (non-blocking).

fn broadcast( &self, message: Message, peers: &[NodeId], ) -> Vec<Result<(), TransportError>>

Broadcast a message to all peers.