Struct StreamedOpen 

pub struct StreamedOpen { /* private fields */ }

Implementations

impl StreamedOpen

pub fn begin( key: &LinkKey, sealed: &[u8], compression: ResourceCompression, ) -> Option<StreamedOpen>

None when the sealed length is no token shape at all. The conclusion’s whole-transfer fallback then refuses it with the stock Malformed.

pub fn advance(&mut self, transfer: &mut [u8], contiguous_byte_len: usize)

pub fn pending_span(&self, contiguous_byte_len: usize) -> Range<usize>

The next chewable whole-block span in token coordinates; empty when the open has caught up with the frontier (or nothing has landed past it yet).

pub fn caught_up(&self) -> bool

Whether conclude has no chewing left to do — the offloaded lane’s gate between finishing in constant work and parking for another span verdict.

pub fn chew_span(&mut self, span: &mut [u8])

advance for a span carried away from its transfer — exactly the bytes pending_span named. This is the pool worker’s whole job: the span decrypts in place here and the verdict copies it back over its ciphertext.

pub fn conclude( self, transfer: &mut [u8], ) -> Result<OpenedStream<'_>, OpenTransferError>

open_transfer’s refusals in the same order, then the stream with everything absorbed so far banked for the verify.

Trait Implementations

impl Debug for StreamedOpen

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

Formats the value using the given formatter.