Enum WriteCompressionEnum

pub enum WriteCompressionEnum<W: Write + Send + Sync + 'static> {
    CompressedOutput(CompressedOutput<W>),
    RawOutput(RawOutput<W>),
    EmptyOutput(EmptyOutput<Sink>),
}

Different options for what to with the events we’re given

Variants

CompressedOutput(CompressedOutput<W>)

Perform (possibly lossy) compression on the ADΔER stream, and arithmetic coding

RawOutput(RawOutput<W>)

Write the ADΔER stream as raw events

EmptyOutput(EmptyOutput<Sink>)

An empty output stream. Send all the data into the void.

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> From<EmptyOutput<Sink>> for WriteCompressionEnum<W>

fn from(v: EmptyOutput<Sink>) -> WriteCompressionEnum<W>

Converts to this type from the input type.

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

fn from(v: RawOutput<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> TryInto<EmptyOutput<Sink>> for WriteCompressionEnum<W>

type Error = &'static str

The type returned in the event of a conversion error.

fn try_into( self, ) -> Result<EmptyOutput<Sink>, <Self as TryInto<EmptyOutput<Sink>>>::Error>

Performs the conversion.

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

type Error = &'static str

The type returned in the event of a conversion error.

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

Performs the conversion.

impl<W: Write + Send + Sync + 'static> WriteCompression<W> for WriteCompressionEnum<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, __enum_dispatch_arg_0: &[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, __enum_dispatch_arg_0: 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.)