Struct barter_data::streams::Streams

pub struct Streams<T> {
    pub streams: HashMap<ExchangeId, UnboundedReceiver<T>>,
}

Ergonomic collection of exchange MarketEvent<T> receivers.

Fields

streams: HashMap<ExchangeId, UnboundedReceiver<T>>

Implementations

impl<T> Streams<T>

pub fn builder<Kind>() -> StreamBuilder<Kind>where
    Kind: SubKind,

Construct a StreamBuilder for configuring new MarketEvent<SubKind::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<UnboundedReceiver<T>>

Remove an exchange mpsc::UnboundedReceiver from the Streams HashMap.

pub async fn join(self) -> UnboundedReceiver<T>where
    T: Send + 'static,

Join all exchange mpsc::UnboundedReceiver streams into a unified mpsc::UnboundedReceiver.

pub async fn join_map(self) -> StreamMap<ExchangeId, UnboundedReceiverStream<T>>

Join all exchange mpsc::UnboundedReceiver streams into a unified StreamMap.

Trait Implementations

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

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

Formats the value using the given formatter.