Struct adder_codec_core::codec::compressed::stream::CompressedOutput

pub struct CompressedOutput<W: Write> { /* private fields */ }

Write compressed ADΔER data to a stream.

Trait Implementations

impl<W: Write> WriteCompression<W> for CompressedOutput<W>

fn new(meta: CodecMetadata, writer: W) -> Self

A struct implementing WriteCompression should take ownership of the writer.

fn magic(&self) -> [u8; 5]

The magic number for this compression format.

fn meta(&self) -> &CodecMetadata

Returns a reference to the metadata

fn meta_mut(&mut self) -> &mut CodecMetadata

Returns a mutable reference to the metadata

fn write_bytes(&mut self, bytes: &[u8]) -> Result<()>

Write the given bytes to the stream

fn byte_align(&mut self) -> Result<()>

Align the bitstream to the next byte boundary

fn into_writer(self: Box<Self>) -> Option<W>

Consumes the compression stream and returns the underlying writer.

fn flush_writer(&mut self) -> Result<()>

Flush the BitWriter. Does not flush the internal BufWriter.

fn compress(&self, _data: &[u8]) -> Vec<u8>

Compress the given bytes.

fn ingest_event(&mut self, _event: &Event) -> Result<(), CodecError>

Take in an event and process it. May or may not write to the output, depending on the state of the stream (Is it ready to write events? Is it accumulating/reorganizing events? etc.)