Module barter_data::streams::builder

Defines the StreamBuilder and MultiStreamBuilder APIs for ergonomically initialising MarketStream Streams.

Modules

• dynamic
• multi
  Defines the MultiStreamBuilder API for ergonomically initialising a common Streams<Output> from multiple StreamBuilder<SubscriptionKind>s.

Structs

• ExchangeChannel
  Convenient type that holds the mpsc::UnboundedSender and mpsc::UnboundedReceiver for a MarketEvent<T> channel.
• StreamBuilder
  Builder to configure and initialise a Streams<MarketEvent<SubscriptionKind::Event> instance for a specific SubscriptionKind.

Functions

• validate
  Validate the provided collection of Subscriptions, ensuring that the associated exchange supports every Subscription InstrumentKind.

Type Aliases

• SubscribeFuture
  Communicative type alias representing the Future result of a Subscription validate call generated whilst executing StreamBuilder::subscribe.