Enum PeerRecvStream 

pub enum PeerRecvStream {
    Plain(RecvStream),
    Encrypted(CryptoRecvStream),
    Prefixed {
        prefix: VecDeque<u8>,
        inner: Box<PeerRecvStream>,
    },
}

Variants

Plain(RecvStream)

Encrypted(CryptoRecvStream)

Prefixed

Plaintext bytes read by a host-side protocol classifier, followed by the original protected stream. This lets one native host inspect a channel envelope without stealing or duplicating the admitted-stream queue.

Fields

prefix: VecDeque<u8>

inner: Box<PeerRecvStream>

Implementations

impl PeerRecvStream

pub fn plain(inner: RecvStream) -> Self

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

pub fn encrypted_with_prefix( inner: RecvStream, key: [u8; 32], prefix: &[u8], ) -> Result<Self>

pub fn is_encrypted(&self) -> bool

pub fn with_plaintext_prefix(self, prefix: impl IntoIterator<Item = u8>) -> Self

Restore plaintext consumed during bounded host-side classification.

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

pub fn into_plain(self) -> RecvStream

Trait Implementations

impl Debug for PeerRecvStream

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

Formats the value using the given formatter.