Struct QuicConn 

pub struct QuicConn {
    inner: Connection,
    peer_endpoint: Endpoint,
    local_endpoint: Endpoint,
}

A QUIC connection. Manages streams and datagrams. This is NOT a single read/write channel — it is a stream factory.

Fields

inner: Connection

peer_endpoint: Endpoint

local_endpoint: Endpoint

Implementations

impl QuicConn

pub async fn open_bi(&self) -> Result<(QuicSendStream, QuicRecvStream)>

Open a new bidirectional stream.

pub async fn open_uni(&self) -> Result<QuicSendStream>

Open a new unidirectional (send-only) stream.

pub async fn accept_bi(&self) -> Result<(QuicSendStream, QuicRecvStream)>

Accept a bidirectional stream opened by the peer.

pub async fn accept_uni(&self) -> Result<QuicRecvStream>

Accept a unidirectional (receive-only) stream from the peer.

pub fn send_datagram(&self, data: Bytes) -> Result<()>

Send an unreliable datagram over the connection. Zero-copy — ownership of the Bytes allocation is passed to quinn.

pub async fn recv_datagram(&self) -> Result<Bytes>

Receive an unreliable datagram. Zero-copy — wraps the allocation returned by quinn.

pub fn max_datagram_size(&self) -> Option<usize>

Maximum datagram size the peer supports, or None if unsupported.

pub fn peer_endpoint(&self) -> Result<Endpoint>

Remote peer’s address.

pub fn local_endpoint(&self) -> Result<Endpoint>

Local address.

pub fn rtt(&self) -> Duration

Current round-trip time estimate.

pub fn close(&self, code: u32, reason: &[u8])

Close the connection gracefully.

pub async fn closed(&self) -> ConnectionError

Wait for the connection to be closed (by us or the peer).

pub fn inner(&self) -> &Connection

Returns a reference to the inner quinn connection.

pub fn peer_certificates(&self) -> Option<Vec<CertificateDer<'static>>>

Peer certificate chain from the QUIC TLS handshake. Quinn returns a type-erased Box<dyn Any>; for rustls-based QUIC (which is what karyon uses) it downcasts to Vec<CertificateDer<'static>>.

Trait Implementations

impl StreamMux for QuicConn

async fn open_stream(&self) -> Result<Box<dyn ByteStream>>

Open a new bidirectional stream.

async fn accept_stream(&self) -> Result<Box<dyn ByteStream>>

Accept a stream opened by the peer.

fn peer_endpoint(&self) -> Option<Endpoint>

Remote peer address.

fn local_endpoint(&self) -> Option<Endpoint>

Local address.