Struct barter_data::streams::builder::StreamBuilder

pub struct StreamBuilder<Kind>
where
    Kind: SubscriptionKind,
{
    pub channels: HashMap<ExchangeId, ExchangeChannel<MarketEvent<Instrument, Kind::Event>>>,
    pub futures: Vec<SubscribeFuture>,
}

Builder to configure and initialise a Streams<MarketEvent<SubscriptionKind::Event> instance for a specific SubscriptionKind.

Fields

channels: HashMap<ExchangeId, ExchangeChannel<MarketEvent<Instrument, Kind::Event>>>

futures: Vec<SubscribeFuture>

Implementations

impl<Kind> StreamBuilder<Kind>

where Kind: SubscriptionKind,

pub fn new() -> Self

Construct a new Self.

pub fn subscribe<SubIter, Sub, Exchange>(self, subscriptions: SubIter) -> Self

where SubIter: IntoIterator<Item = Sub>, Sub: Into<Subscription<Exchange, Instrument, Kind>>, Exchange: StreamSelector<Instrument, Kind> + Ord + Send + Sync + 'static, Kind: Ord + Send + Sync + 'static, Kind::Event: Send, Subscription<Exchange, Instrument, Kind>: Identifier<Exchange::Channel> + Identifier<Exchange::Market>,

Add a collection of Subscriptions to the StreamBuilder that will be actioned on a distinct WebSocket connection.

Note that Subscriptions are not actioned until the init() method is invoked.

pub async fn init( self, ) -> Result<Streams<MarketEvent<Instrument, Kind::Event>>, DataError>

Spawn a MarketEvent<SubscriptionKind::Event> consumer loop for each collection of Subscriptions added to StreamBuilder via the subscribe() method.

Each consumer loop distributes consumed MarketEvent<SubscriptionKind::Event>s to the Streams HashMap returned by this method.

Trait Implementations

impl<Kind> Debug for StreamBuilder<Kind>

where Kind: SubscriptionKind,

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

Formats the value using the given formatter.

impl<Kind> Default for StreamBuilder<Kind>

where Kind: SubscriptionKind + Default, Kind::Event: Default,

fn default() -> StreamBuilder<Kind>

Returns the “default value” for a type.