Struct StreamingAttachmentDecryptor 

pub struct StreamingAttachmentDecryptor<R> {
    inner: R,
    state: StreamDecryptorState,
    plaintext_buf: Vec<u8>,
    inner_eof: bool,
}

AsyncRead adapter that decrypts a streaming-attachment-encrypted wire stream from R and exposes the decrypted plaintext via [AsyncRead]. The cipher is selected by the 1-byte discriminator at the start of the wire and must agree with the supplied key.

Fields

inner: R

state: StreamDecryptorState

plaintext_buf: Vec<u8>

Decrypted plaintext awaiting copy into the caller’s buffer.

inner_eof: bool

Set once the inner reader has returned EOF; triggers the underlying update(_, true).

Implementations

impl<R> StreamingAttachmentDecryptor<R>

pub fn new<Ids: KeySlotIds>( key_slot: Ids::Symmetric, ctx: KeyStoreContext<'_, Ids>, inner: R, ) -> Result<Self, CryptoError>

Construct a decryptor. The key variant determines which cipher’s wire format is expected; the discriminator on the wire is validated against it on the first byte.

fn drain_plaintext_into(&mut self, buf: &mut ReadBuf<'_>) -> bool

Drains the plaintext buffer into the passed in ReadBuf. Returns true if any bytes were drained.

fn feed_bytes_to_decryptor(&mut self, data: &[u8]) -> Result<()>

fn finalize_underlying(&mut self) -> Result<()>

Trait Implementations

impl<R: AsyncRead + Unpin> AsyncRead for StreamingAttachmentDecryptor<R>

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

Attempts to read from the AsyncRead into buf.