Struct SymbolSplitter 

pub struct SymbolSplitter<E, F, M> { /* private fields */ }

Splits a stream by symbol.

It’s generic over SymbolIndex, allowing it to work with both TsSymbolMap and PitSymbolMap.

Implementations

impl<E, F, M> SymbolSplitter<E, F, M>

where F: Fn(&str, Option<Metadata>) -> Result<E>, M: SymbolIndex,

pub fn new(build_encoder: F, symbol_map: M) -> Self

Creates a new splitter that will split the input stream by symbol, creating a separate sub-encoder for each symbol using build_encoder.

The symbol_map is used to look up the symbol for each record based on the instrument ID (and optionally the timestamp for TsSymbolMap).

Trait Implementations

impl<E: Debug, F: Debug, M: Debug> Debug for SymbolSplitter<E, F, M>

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl<E, F, M> Splitter<E> for SymbolSplitter<E, F, M>

where F: Fn(&str, Option<Metadata>) -> Result<E>, M: SymbolIndex,

fn sub_encoder<R>( &mut self, metadata: Option<&Metadata>, record: &R, ) -> Result<Option<&mut E>>

where R: Record,

Returns the encoder for the given record, or None if the record should be ignored.

fn sub_encoders<'a>(&'a mut self) -> impl Iterator<Item = &'a mut E>

where E: 'a,

Returns an iterator over all active sub-encoders.