Struct ReadHalf

pub struct ReadHalf<T, U> { /* private fields */ }

Async Encryption Read Half

Implementations

impl<T, A, S> ReadHalf<T, Decryptor<A, S>>

where S: StreamPrimitive<A>, A: AeadInPlace, A::NonceSize: Sub<<S as StreamPrimitive<A>>::NonceOverhead>, NonceSize<A, S>: ArrayLength<u8>,

pub fn new(inner: T, decryptor: Decryptor<A, S>) -> Self

pub fn with_capacity(inner: T, decryptor: Decryptor<A, S>, size: usize) -> Self

pub fn buffer(&self) -> &[u8]

Return the contents of the internal buffer at the current position, for diagnostic purposes.

For each message available in the buffer, the first 4 bytes are the message length encoded as a little endian u32. The end of the buffer may contain incomplete data.

Trait Implementations

impl<R: AsyncRead, A, S> AsyncBufRead for ReadHalf<R, Decryptor<A, S>>

where S: StreamPrimitive<A>, A: AeadInPlace, A::NonceSize: Sub<<S as StreamPrimitive<A>>::NonceOverhead>, NonceSize<A, S>: ArrayLength<u8>,

fn poll_fill_buf( self: Pin<&mut Self>, cx: &mut Context<'_>, ) -> Poll<Result<&[u8]>>

Attempts to return the contents of the internal buffer, filling it with more data from the inner reader if it is empty.

fn consume(self: Pin<&mut Self>, amt: usize)

Tells this buffer that amt bytes have been consumed from the buffer, so they should no longer be returned in calls to poll_read.

impl<T, A, S> AsyncRead for ReadHalf<T, Decryptor<A, S>>

where T: AsyncRead, S: StreamPrimitive<A>, A: AeadInPlace, A::NonceSize: Sub<<S as StreamPrimitive<A>>::NonceOverhead>, NonceSize<A, S>: ArrayLength<u8>,

fn poll_read( self: Pin<&mut Self>, cx: &mut Context<'_>, buf: &mut ReadBuf<'_>, ) -> Poll<Result<()>>

The poll read simply tries to produce a value from the internal buffer. If no value is produced, it then tries to poll more bytes from the inner reader

This function may return a std::io::ErrorKind::InvalidData if it is not possible to decrypt the message, in this case, further read attempts will always produce the same error.

impl<'__pin, T, U> Unpin for ReadHalf<T, U>

where PinnedFieldsOf<__Origin<'__pin, T, U>>: Unpin,