Struct splinter::peer::interconnect::PeerInterconnect

pub struct PeerInterconnect { /* private fields */ }

PeerInterconnect will receive incoming messages from peers and dispatch them to the NetworkMessageType handlers. It will also receive messages from handlers that need to be sent to other peers.

When an incoming message is received, the connection ID is converted to a peer ID. The reverse is done for an outgoing message. If a message is received from an unknown connection, the PeerInterconnect will request the current peers from the PeerManager and update the local map of peers.

Implementations

impl PeerInterconnect

pub fn new_network_sender(&self) -> NetworkMessageSender

Creates a new NetworkMessageSender that can be used to send messages to peers.

Trait Implementations

impl ShutdownHandle for PeerInterconnect

fn signal_shutdown(&mut self)

Instructs the component to begin shutting down.

For components with threads, this should break out of any loops and ready the threads for being joined.

fn wait_for_shutdown(self) -> Result<(), InternalError>

Waits until the the component has completely shutdown.

For components with threads, the threads should be joined during the call to wait_for_shutdown.