Struct CompressedWriteContext 

pub struct CompressedWriteContext { /* private fields */ }

A write context specifically for compressed output.

This wraps WriteContext to handle the finish() call properly for compressed writers, which need to call finish() on the encoder before the atomic file swap.

Implementations

impl CompressedWriteContext

pub fn new( writer: CompressedWriter, current_state: Value, observation_count: usize, snapshot_interval: Option<usize>, finish_strategy: FinishStrategy, diagnostics: DiagnosticCollector, ) -> Self

Create a new compressed write context.

pub fn write_observations<P: AsRef<Path>>( &mut self, files: &[P], ) -> Result<usize, Vec<Diagnostic>>

Write observations for a list of JSON files.

pub fn write_raw(&mut self, bytes: &[u8]) -> Result<(), Vec<Diagnostic>>

Write raw bytes to the output (used for copying existing archive content).

pub fn finish(self) -> Result<DiagnosticCollector, Vec<Diagnostic>>

Finish the write operation.

This finishes the compression encoder, then performs any atomic file operations needed.