Struct EncryptedSocketStreamReader 

pub struct EncryptedSocketStreamReader<'scope> { /* private fields */ }

Plaintext input which drives its retained TLS receive future. No lock spans an asynchronous wait; paused input does not prevent application output.

Trait Implementations

impl ReadableStream for EncryptedSocketStreamReader<'_>

async fn read_into( &mut self, buffer: &mut [u8], cancellation: &Cancellation, ) -> OperationResult<usize>

Read a possibly short prefix. Empty storage does not establish EOF.

fn try_read_into(&mut self, buffer: &mut [u8]) -> Result<usize>

Attempt one read now, without waiting. Unlike polling read_into once, this reaches the transport, so it observes input, EOF and errors already queued there. WouldBlock means no input is available now; zero with nonempty storage is EOF, and empty storage returns zero. Other errors are as for read_into, except that a cancelled transport reports ConnectionAborted, since there is no operation cancellation to report and the input cannot resume. Wrappers must forward this rather than polling a read.

async fn close(&mut self) -> Result<()>

Retire this direction. Transport ownership and final closure are separate.