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<SubKind>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>) -> Selfwhere
    Output: From<MarketEvent<Kind::Event>> + Send + 'static,
    Kind: SubKind + 'static,
    Kind::Event: Send,

Add a StreamBuilder<SubKind> to the MultiStreamBuilder. Creates a Future that calls StreamBuilder::init and maps the SubKind::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<SubKind> that was added to the MultiStreamBuilder and map all Streams<SubKind::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.