Struct MergeDecoder 

pub struct MergeDecoder<D> { /* private fields */ }

Merges the DBN decoding streams from one or more other decoders. Both metadata and the record streams are merged.

Implementations

impl<D> Decoder<D>

where D: DbnMetadata + DecodeRecordRef,

pub fn new(decoders: Vec<D>) -> Result<Self>

Creates a new merge decoder from the given decoders. Both the DBN metadata and the records will be merged.

Errors

This function returns an error if decoders is empty. Errors can also result from failing to merge the DBN metadata. It will also return an error if one of the inner decoders returns an error while decoding the first record. A decoder returning Ok(None) does not result in a failure.

Trait Implementations

impl<D> DbnMetadata for Decoder<D>

fn metadata(&self) -> &Metadata

Returns an immutable reference to the decoded Metadata.

fn metadata_mut(&mut self) -> &mut Metadata

Returns a mutable reference to the decoded Metadata.

impl<D> DecodeRecord for Decoder<D>

where D: LastRecord + DecodeRecordRef,

fn decode_record<T: HasRType>(&mut self) -> Result<Option<&T>>

Tries to decode a reference to a single record of type T. Returns Ok(None) if the input has been exhausted.

fn decode_records<T: HasRType + Clone>(self) -> Result<Vec<T>>

where Self: Sized,

Tries to decode all records into a Vec. This eagerly decodes the data.

impl<D> DecodeRecordRef for Decoder<D>

where D: LastRecord + DecodeRecordRef,

fn decode_record_ref(&mut self) -> Result<Option<RecordRef<'_>>>

Tries to decode a generic reference a record. Returns Ok(None) if input has been exhausted.

fn decode_buf_iter(&mut self) -> impl Iterator<Item = Result<RecordBuf>> + '_

Returns an Iterator of owned RecordBufs decoded from this reader.

impl<D> DecodeStream for Decoder<D>

where D: LastRecord + DecodeRecordRef,

fn decode_stream<T: HasRType>(self) -> StreamIterDecoder<Self, T>

where Self: Sized,

Converts the decoder into a streaming iterator of records of type T. This lazily decodes the data.