Struct Streams 

pub struct Streams<T> {
    pub streams: FnvHashMap<ExchangeId, UnboundedRx<T>>,
}

Ergonomic collection of exchange market event receivers.

Fields

streams: FnvHashMap<ExchangeId, UnboundedRx<T>>

Implementations

impl<T> Streams<T>

pub fn builder<InstrumentKey, Kind>() -> StreamBuilder<InstrumentKey, Kind>

where Kind: SubscriptionKind,

Construct a StreamBuilder for configuring new market event Streams.

pub fn builder_multi() -> MultiStreamBuilder<T>

Construct a MultiStreamBuilder for configuring new MarketEvent<T> Streams.

pub fn select( &mut self, exchange: ExchangeId, ) -> Option<impl Stream<Item = T> + '_>

Remove an exchange market event Stream from the Streams HashMap.

pub fn select_all(self) -> impl Stream<Item = T>

Select and merge every exchange Stream using select_all.

Trait Implementations

impl<T: Debug> Debug for Streams<T>

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

Formats the value using the given formatter.