Struct barter_data::builder::StreamBuilder

pub struct StreamBuilder {
    pub exchange_subscriptions: HashMap<ExchangeId, Vec<Subscription>>,
}

Builder to configure and initialise Streams instances.

Fields

exchange_subscriptions: HashMap<ExchangeId, Vec<Subscription>>

Implementations

impl StreamBuilder

pub fn subscribe<SubIter, Sub>(self, subscriptions: SubIter) -> Self where
    SubIter: IntoIterator<Item = Sub>,
    Sub: Into<Subscription>, 

Add a collection of Subscriptions to the StreamBuilder. Note that the provided Subscriptions are not actioned until the init() method is invoked.

pub fn subscribe_exchange<SubIter, S>(
    self,
    exchange: ExchangeId,
    subscriptions: SubIter
) -> Self where
    SubIter: IntoIterator<Item = (S, S, InstrumentKind, SubKind)>,
    S: Into<Symbol>, 

Add a set of Subscriptions for an exchange to the StreamBuilder. Note that the provided Subscriptions are not actioned until the init() method is invoked.

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

Spawn a MarketEvent consumer loop for each exchange. Each consumer loop distributes consumed MarketEvents to the Streams HashMap (returned by this method).

Trait Implementations

impl Debug for StreamBuilder

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

Formats the value using the given formatter.

impl Validator for StreamBuilder

fn validate(self) -> Result<Self, SocketError> where
    Self: Sized, 

Check if Self is valid for some use case.