weave-locus · stream

Reviewed implementation boundary: Rollback records a marker; mount descriptions and governance metadata alone do not execute mounting or enforce signature authorization. Operations can have separate metadata/blob failure points. See /libraries/locus/overview.

Source: sigil/weave/models/locus/src/stream.rs. SHA-256: bb8b074d9b96ba0f89a8858dd97b048896499edadbf699aed581694000b5c190.

This reference follows declared source modules, retains conditional attributes, and includes public declarations and implementation methods. Private-module re-exports and trait resolution require the compiler; this is a source reference, not a claim that every listed item is a root import. Function bodies and constant values are omitted.

stream::ReadStream

Stream for reading file data

pub struct ReadStream {

}

Source line: 14.

stream::ReadStream::new

Create a new read stream

pub fn new(data: Bytes) -> Self;

Source line: 24.

stream::ReadStream::remaining

Get the remaining bytes

pub fn remaining(&self) -> usize;

Source line: 29.

stream::WriteStream

Stream for writing file data

pub struct WriteStream {

}

Source line: 53.

stream::WriteStream::new

Create a new write stream

pub fn new(max_size: usize) -> Self;

Source line: 66.

stream::WriteStream::with_flush_callback

Set flush callback

pub fn with_flush_callback<F>(mut self, callback: F) -> Self
    where
        F: Fn(Bytes) -> Result<()> + Send + Sync + 'static,;

Source line: 75.

stream::WriteStream::into_bytes

Get the accumulated data

pub fn into_bytes(self) -> Bytes;

Source line: 84.