Struct CompressedOutput

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

Write compressed ADΔER data to a stream.

Implementations

impl<W: Write + Send + Sync + 'static> CompressedOutput<W>

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

Create a new compressed output stream.

Trait Implementations

impl<W: Write + Send + Sync + 'static> From<CompressedOutput<W>> for WriteCompressionEnum<W>

fn from(v: CompressedOutput<W>) -> WriteCompressionEnum<W>

Converts to this type from the input type.

impl<W: Write + Send + Sync + 'static> TryInto<CompressedOutput<W>> for WriteCompressionEnum<W>

type Error = &'static str

The type returned in the event of a conversion error.

fn try_into( self, ) -> Result<CompressedOutput<W>, <Self as TryInto<CompressedOutput<W>>>::Error>

Performs the conversion.

impl<W: Write + Send + Sync + 'static> WriteCompression<W> for CompressedOutput<W>

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<(), Error>

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) -> 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 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.)