Struct MasqueRelaySocket 

pub struct MasqueRelaySocket { /* private fields */ }

A virtual UDP socket that tunnels packets through a MASQUE relay via a persistent QUIC stream with length-prefixed framing.

Implementations

impl MasqueRelaySocket

pub fn new( send_stream: SendStream, recv_stream: RecvStream, relay_public_addr: SocketAddr, ) -> Arc<Self>

Create a new stream-based relay socket.

Spawns two background tasks:

• Read from recv_stream, decode frames, queue for poll_recv
• Read from send_tx channel, write length-prefixed frames to send_stream

Trait Implementations

impl AsyncUdpSocket for MasqueRelaySocket

fn create_sender(&self) -> Pin<Box<dyn UdpSender>>

Create a UdpSender with independent write-readiness notifications.

fn poll_recv( &self, cx: &mut Context<'_>, bufs: &mut [IoSliceMut<'_>], meta: &mut [RecvMeta], ) -> Poll<Result<usize>>

Receive UDP datagrams, or register to be woken if receiving may succeed in the future

fn local_addr(&self) -> Result<SocketAddr>

Look up the local IP address and port used by this socket

fn may_fragment(&self) -> bool

Whether datagrams might get fragmented into multiple parts

fn max_receive_segments(&self) -> usize

Maximum number of datagrams that might be described by a single RecvMeta

impl Debug for MasqueRelaySocket

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

Formats the value using the given formatter.