Struct ConnectUdpSocket 

pub struct ConnectUdpSocket<T = Upgraded> { /* private fields */ }

Available on crate feature masque only.

A DatagramSocket carrying UDP payloads through a CONNECT-UDP tunnel (RFC 9298).

Wraps the HttpDatagramSession of an accepted tunnel on any HTTP version, so a QUIC endpoint, a relay or a proxy can use the tunnel as a UDP socket fixed to one peer. Payloads travel with Context ID 0; datagrams for other contexts are dropped and counted. Sending never waits for delivery, but a full queue applies backpressure (Pending) instead of dropping older payloads. Native HTTP/3 payloads above the current limit are dropped and counted, never re-sent as capsules (RFC 9298 §6.1).

Implementations

impl<T> ConnectUdpSocket<T>

where T: AsyncRead + AsyncWrite + ExtensionsRef + Send + 'static,

pub fn new( exec: &Executor, session: HttpDatagramSession<T>, local: SocketAddress, peer: SocketAddress, config: ConnectUdpSocketConfig, ) -> ConnectUdpSocket<T>

Turn an established tunnel’s session into a socket fixed to peer.

Build the session with session_config.

local and peer are what Socket reports: the target’s address on the client side, the client’s or a documented placeholder on the proxy side. IPv4-mapped IPv6 addresses are reported as IPv4.

impl<T> ConnectUdpSocket<T>

pub fn close_reason(&self) -> Option<ConnectUdpClose>

Why the tunnel stopped, once it did.

pub fn max_payload(&self) -> usize

The largest UDP payload that can be sent now: the native datagram limit minus the Context ID, or the RFC 9298 maximum on capsule carriers.

Trait Implementations

impl<T> DatagramSocket for ConnectUdpSocket<T>

where T: AsyncRead + Send + 'static,

type Sender = ConnectUdpSender

Independently wakeable send handle created by this socket.

fn create_sender(&self) -> <ConnectUdpSocket<T> as DatagramSocket>::Sender

Create a send handle with independent readiness registration.

fn poll_recv( &mut self, cx: &mut Context<'_>, buffers: &mut [IoSliceMut<'_>], metadata: &mut [DatagramMetadata], ) -> Poll<Result<usize, DatagramError>>

Receive one or more datagrams, or register for readiness.

fn capabilities(&self) -> DatagramCapabilities

Current runtime-detected capabilities.

impl<T> Debug for ConnectUdpSocket<T>

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

Formats the value using the given formatter.

impl<T> ExtensionsRef for ConnectUdpSocket<T>

fn extensions(&self) -> &Extensions

Get reference to the underlying Extensions store

impl<T> Socket for ConnectUdpSocket<T>

where T: Send + 'static,

fn local_addr(&self) -> Result<SocketAddress, Error>

Try to get the local address of the socket.

fn peer_addr(&self) -> Result<SocketAddress, Error>

Try to get the remote address of the socket.