Struct Connection 

pub struct Connection { /* private fields */ }

A QUIC connection driven by a crate::Worker, usable as a MoQ transport.

Created by Endpoint (or its client::connect / server::accept shorthands), already established. Clones share the connection; each carries its own parking so concurrent pending operations don’t trample each other’s wakeups. Dropping every handle (and every stream) drops the driver’s Rc peers, but the driver itself keeps the connection alive until it ends; close explicitly with close (which moq’s session machine does).

That close only records the code: the driver task is what frames the CONNECTION_CLOSE and hands it to the socket. Drive the worker until poll_closed resolves before stopping it, or the packet is never built and the peer idles out instead.

Implementations

impl Connection

pub fn peer_chain(&self) -> Option<Vec<Vec<u8>>>

The peer’s certificate chain in DER, leaf first, or None if it presented none.

A server only sees one when it asked (ClientAuth), and TLS already validated it against the configured roots by the time this connection exists: an invalid chain fails the handshake instead. So a Some here is an authenticated peer, and the chain is what names it.

pub fn remote_addr(&self) -> SocketAddr

The peer’s address as of the handshake; a peer that migrates later keeps its connection but not this value.

pub fn server_name(&self) -> Option<&str>

The SNI the client presented, or None if it sent none. Always None on a dialed connection.

Trait Implementations

impl Clone for Connection

fn clone(&self) -> Self

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for Connection

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl Session for Connection

type SendStream = SendStream

The outgoing stream type. Only the poll half is required, so a !Send session can hang !Send streams off it.

type RecvStream = RecvStream

The incoming stream type. Only the poll half is required, so a !Send session can hang !Send streams off it.

type Error = Error

The error type for every operation on this session.

fn poll_accept_uni( &mut self, cx: &mut Context<'_>, ) -> Poll<Result<Self::RecvStream, Self::Error>>

Poll for a unidirectional stream created by the peer.

fn poll_accept_bi( &mut self, cx: &mut Context<'_>, ) -> Poll<Result<(Self::SendStream, Self::RecvStream), Self::Error>>

Poll for a bidirectional stream created by the peer.

fn poll_open_uni( &mut self, cx: &mut Context<'_>, ) -> Poll<Result<Self::SendStream, Self::Error>>

Poll to open a unidirectional stream, which blocks while there are too many concurrent streams.

fn poll_open_bi( &mut self, cx: &mut Context<'_>, ) -> Poll<Result<(Self::SendStream, Self::RecvStream), Self::Error>>

Poll to open a bidirectional stream, which blocks while there are too many concurrent streams.

fn poll_send_datagram( &mut self, cx: &mut Context<'_>, payload: &[u8], ) -> Poll<Result<(), Self::Error>>

Poll to send a datagram over the network.

fn poll_recv_datagram( &mut self, cx: &mut Context<'_>, ) -> Poll<Result<Bytes, Self::Error>>

Poll for a datagram from the network.

fn max_datagram_size(&self) -> usize

The maximum size of a datagram that can be sent.

fn protocol(&self) -> Option<&str>

Return the application protocol negotiated for this session, if any.

fn close(&mut self, code: u32, reason: &str)

Close the connection immediately with a code and reason.

fn poll_closed(&mut self, cx: &mut Context<'_>) -> Poll<Self::Error>

Poll until the connection is closed by either side.

fn stats(&self) -> impl Stats

Return connection-level statistics.