Struct barter_data::streams::builder::multi::MultiStreamBuilder

pub struct MultiStreamBuilder<Output> {
    pub channels: HashMap<ExchangeId, ExchangeChannel<Output>>,
    pub futures: Vec<BuilderInitFuture>,
}

Builder to configure and initialise a common Streams<Output> instance from multiple StreamBuilder<SubscriptionKind>s.

Fields

channels: HashMap<ExchangeId, ExchangeChannel<Output>>

futures: Vec<BuilderInitFuture>

Implementations

impl<Output> MultiStreamBuilder<Output>

pub fn new() -> Self

Construct a new Self.

pub fn add<Kind>(self, builder: StreamBuilder<Kind>) -> Self

where Output: From<MarketEvent<Instrument, Kind::Event>> + Send + 'static, Kind: SubscriptionKind + 'static, Kind::Event: Send,

Add a StreamBuilder<SubscriptionKind> to the MultiStreamBuilder. Creates a Future that calls StreamBuilder::init and maps the SubscriptionKind::Event into a common Output.

Note that the created Future is not awaited until the MultiStreamBuilder::init method is invoked.

pub async fn init(self) -> Result<Streams<Output>, DataError>

Initialise each StreamBuilder<SubscriptionKind> that was added to the MultiStreamBuilder and map all Streams<SubscriptionKind::Event> into a common Streams<Output>.

Trait Implementations

impl<Output> Debug for MultiStreamBuilder<Output>

where Output: Debug,

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

Formats the value using the given formatter.

impl<Output: Default> Default for MultiStreamBuilder<Output>

fn default() -> MultiStreamBuilder<Output>

Returns the “default value” for a type.