Enum PeerSendStream 

pub enum PeerSendStream {
    Plain(SendStream),
    Encrypted(CryptoSendStream),
}

Variants

Plain(SendStream)

Encrypted(CryptoSendStream)

Implementations

impl PeerSendStream

pub fn plain(inner: SendStream) -> Self

pub fn encrypted(inner: SendStream, key: [u8; 32]) -> Self

pub fn is_encrypted(&self) -> bool

pub async fn write_all(&mut self, buf: &[u8]) -> Result<()>

pub async fn flush(&mut self) -> Result<()>

pub fn finish(self) -> Result<()>

pub async fn finish_and_wait_for_peer(self, timeout: Duration) -> Result<()>

Finish a short control response and keep its QUIC send half alive until the peer has acknowledged the buffered bytes (or the bounded wait expires). finish() alone only queues the FIN; a concurrent physical-leg replacement can otherwise close the connection before the verdict is observable by the admission dialer.

pub fn into_plain(self) -> SendStream

Trait Implementations

impl Debug for PeerSendStream

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

Formats the value using the given formatter.