Struct barter_data::streams::Streams

pub struct Streams<Kind>where
    Kind: SubKind,{
    pub streams: HashMap<ExchangeId, UnboundedReceiver<Market<Kind::Event>>>,
}

Collection of exchange Market<Event> streams for a specific SubKind.

Fields

streams: HashMap<ExchangeId, UnboundedReceiver<Market<Kind::Event>>>

Implementations

impl<Kind> Streams<Kind>where
    Kind: SubKind,

pub fn builder() -> StreamBuilder<Kind>

Construct a StreamBuilder for configuring new Market<Event> Streams.

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

Remove an exchange Market<Event> mpsc::UnboundedReceiver from the Streams HashMap.

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

Join all exchange Market<Event> mpsc::UnboundedReceiver streams into a unified mpsc::UnboundedReceiver.

pub async fn join_map(
    self
) -> StreamMap<ExchangeId, UnboundedReceiverStream<Market<Kind::Event>>>

Join all exchange Market<Event> mpsc::UnboundedReceiver streams into a unified StreamMap.

Trait Implementations

impl<Kind> Debug for Streams<Kind>where
    Kind: SubKind + Debug,
    Kind::Event: Debug,

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

Formats the value using the given formatter.