Struct MuxConnection 

pub(crate) struct MuxConnection {
    send_queues: HashMap<ProtocolID, Arc<AsyncQueue<PeerNetMsg>>>,
    recv_queues: HashMap<ProtocolID, Arc<AsyncQueue<ProtocolEvent>>>,
    quic_conn: QuicConn,
}

QUIC path: one stream per protocol, each with its own writer task. send_queues and recv_queues are keyed by protocol id.

Fields

send_queues: HashMap<ProtocolID, Arc<AsyncQueue<PeerNetMsg>>>

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

quic_conn: QuicConn

Implementations

impl MuxConnection

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

Open / accept one QUIC stream per negotiated protocol and spawn a reader + writer task for each.

Trait Implementations

impl PeerConnection for MuxConnection

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).