Struct BlobBody 

pub struct BlobBody { /* private fields */ }

A blob as a sized stream of already-final bytes: sealed chunks for an encrypted home, plaintext for a browsable one. Encryption-agnostic and concrete (no dyn Stream). next_part hands the bytes to a streaming upload in bounded windows so a large blob is never held whole in memory; the only collect is the single-request path for blobs at or below a provider’s multipart threshold.

Built by the cipher layer (CloudCipher::open_body), which knows scope→key and plaintext-vs-encrypted, or by from_bytes for an in-memory control object / the test backend.

Implementations

impl BlobBody

pub fn from_bytes(data: Vec<u8>) -> BlobBody

A body over already-final in-memory bytes — a sealed control object, or a test payload. len is the byte count.

pub async fn from_file(path: &Path) -> Result<BlobBody, String>

pub fn from_test_reader(len: u64, reader: PlaintextReader) -> BlobBody

pub fn len(&self) -> u64

Total bytes this body yields (encrypted or plaintext length).

pub fn is_empty(&self) -> bool

Whether the body yields no bytes.

pub async fn next_part( &mut self, min: usize, ) -> Result<Option<Bytes>, CloudHomeError>

Return at least min bytes — exactly min when more remain, the remainder at EOF — or None once fully drained. The driver calls this with the provider’s part size, so every part except the last is exactly that size.

pub async fn collect(self) -> Result<Vec<u8>, CloudHomeError>

Drain the whole body into one Vec. Used ONLY by the single-request upload path for blobs at or below a provider’s multipart threshold (bounded small).