Struct StreamingTape

pub struct StreamingTape { /* private fields */ }

Memory-efficient tape that can handle very large computations

Implementations

impl StreamingTape

pub fn new(batch_size: usize) -> Self

Create a new streaming tape

pub fn set_batch_processor<F>(&mut self, processor: F)

where F: Fn(&[TapeNode]) -> Result<(), OptimizeError> + 'static,

Set the batch processor

pub fn add_node(&mut self, node: TapeNode) -> Result<(), OptimizeError>

Add a node to the streaming tape

pub fn flush_batch(&mut self) -> Result<(), OptimizeError>

Flush the current batch

pub fn finalize(&mut self) -> Result<(), OptimizeError>

Finalize the streaming tape