Struct barter_data::builder::Streams

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

Collection of exchange MarketEvent streams.

Fields

streams: HashMap<ExchangeId, UnboundedReceiver<Event<MarketEvent>>>

Implementations

impl Streams

pub fn builder() -> StreamBuilder

Construct a StreamBuilder for configuring new MarketEvent Streams.

pub fn select(
    &mut self,
    exchange: ExchangeId
) -> Option<UnboundedReceiver<Event<MarketEvent>>>

Remove an exchange MarketEvent stream from the Streams HashMap.

pub async fn join<Output>(self) -> UnboundedReceiver<Output>where
    Output: From<Event<MarketEvent>> + Send + 'static,

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

pub async fn join_map<Output>(
    self
) -> StreamMap<ExchangeId, Map<UnboundedReceiverStream<Event<MarketEvent>>, fn(_: Event<MarketEvent>) -> Output>>where
    Output: From<Event<MarketEvent>> + Send + 'static,

Join all exchange MarketEvent streams into a unified StreamMap.

Trait Implementations

impl Debug for Streams

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

Formats the value using the given formatter.