Struct OutboundUdpSender 

pub struct OutboundUdpSender { /* private fields */ }

Implementations

impl OutboundUdpSender

pub fn new( sender: UnboundedSender<(u8, SecurityLevel, BytesMut)>, local_addr: SocketAddr, remote_addr: SocketAddr, needs_manual_ka: bool, security_level: SecurityLevel, max_datagram_len: usize, dropped: Arc<Atomic<u64>>, ) -> OutboundUdpSender

max_datagram_len is the transport’s hard per-datagram ceiling (QUIC datagram limit, raw socket safe MTU, or SCTP message limit); security_level is the level every payload is sealed at until Self::set_security_level is called.

pub fn unbounded_send<T>(&self, packet: T) -> Result<(), NetworkError>

where T: Into<BytesMut>,

Enqueues one datagram payload. Fails fast if it cannot fit in a datagram at the current security level; the subsystem itself is never torn down by an oversized payload.

pub fn send_keep_alive(&self) -> bool

pub fn set_security_level(&mut self, security_level: SecurityLevel)

Changes the AEAD level applied to subsequently enqueued payloads. The receiver reads the level from each packet header, so no negotiation is required.

pub fn security_level(&self) -> SecurityLevel

pub fn max_datagram_len(&self) -> usize

The transport’s hard per-datagram ceiling, including the Citadel header and AEAD trailer.

pub fn max_payload_len(&self) -> usize

Largest application payload that fits in one datagram at the current security level.

pub fn dropped_datagrams(&self) -> u64

Number of queued datagrams discarded because the transport sink stalled.

pub fn local_addr(&self) -> SocketAddr

pub fn remote_addr(&self) -> SocketAddr

Trait Implementations

impl Clone for OutboundUdpSender

fn clone(&self) -> OutboundUdpSender

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for OutboundUdpSender

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

Formats the value using the given formatter.

impl MediaDatagramSink for OutboundUdpSender

fn send_datagram(&mut self, buf: BytesMut) -> Result<(), NetworkError>

impl Sink<BytesMut> for OutboundUdpSender

type Error = NetworkError

The type of value produced by the sink when an error occurs.

fn poll_ready( self: Pin<&mut OutboundUdpSender>, cx: &mut Context<'_>, ) -> Poll<Result<(), <OutboundUdpSender as Sink<BytesMut>>::Error>>

Attempts to prepare the Sink to receive a value.

fn start_send( self: Pin<&mut OutboundUdpSender>, item: BytesMut, ) -> Result<(), <OutboundUdpSender as Sink<BytesMut>>::Error>

Begin the process of sending a value to the sink. Each call to this function must be preceded by a successful call to poll_ready which returned Poll::Ready(Ok(())).

fn poll_flush( self: Pin<&mut OutboundUdpSender>, cx: &mut Context<'_>, ) -> Poll<Result<(), <OutboundUdpSender as Sink<BytesMut>>::Error>>

Flush any remaining output from this sink.

fn poll_close( self: Pin<&mut OutboundUdpSender>, cx: &mut Context<'_>, ) -> Poll<Result<(), <OutboundUdpSender as Sink<BytesMut>>::Error>>

Flush any remaining output and close this sink, if necessary.