Struct SingleConnection 

pub(crate) struct SingleConnection {
    send_queue: Arc<AsyncQueue<PeerNetMsg>>,
    recv_queues: HashMap<ProtocolID, Arc<AsyncQueue<ProtocolEvent>>>,
}

TCP / TLS path: one shared writer drains send_queue; a single reader demuxes incoming PeerNetMsgs into the matching recv_queues.

Fields

send_queue: Arc<AsyncQueue<PeerNetMsg>>

recv_queues: HashMap<ProtocolID, Arc<AsyncQueue<ProtocolEvent>>>

Implementations

impl SingleConnection

pub(crate) fn from_queued( queued: QueuedConn, proto_ids: impl IntoIterator<Item = ProtocolID>, task_group: &TaskGroup, stop_chan: Sender<Result<()>>, ) -> Self

Spawn the writer + demux reader and return the connection.

Trait Implementations

impl PeerConnection for SingleConnection

fn send<'life0, 'life1, 'async_trait>( &'life0 self, proto_id: &'life1 ProtocolID, payload: Vec<u8>, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

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

Send pre-encoded payload bytes for proto_id.

fn recv<'life0, 'life1, 'async_trait>( &'life0 self, proto_id: &'life1 ProtocolID, ) -> Pin<Box<dyn Future<Output = Result<ProtocolEvent>> + Send + 'async_trait>>

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

Pop the next event for proto_id. Blocks until a message arrives or shutdown is broadcast.

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

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

Graceful close. Pushes Shutdown to every recv queue and signals the wire (transport-specific).