Struct DynamicSubscribers 

pub struct DynamicSubscribers {}

The subscribers DynamicStreams cannot build for itself.

Most venues are served by a stateless WebSocketSubscriber, which DynamicStreams constructs on its own. A venue whose subscriber carries credentials — or shares one connection among its streams — needs one built by the caller and supplied here, through DynamicStreams::init_with. A subscription to such a venue with no subscriber supplied fails with DataError::SubscriberRequired.

Venues that need one:

• Alpaca (alpaca feature): AlpacaCrypto, AlpacaIex and AlpacaSip.
• London Strategic Edge (lse feature): every Lse* dataset.
• Massive (massive feature): MassiveStocks, MassiveCrypto, MassiveForex and MassiveOptions.

Example

use rustrade_data::exchange::lse::live::LseSubscriber;
use rustrade_data::streams::builder::dynamic::{DynamicStreams, DynamicSubscribers};
use rustrade_data::subscription::SubKind;
use rustrade_instrument::{
    exchange::ExchangeId, instrument::market_data::kind::MarketDataInstrumentKind,
};

let subscribers = DynamicSubscribers::default().with_lse(LseSubscriber::from_env()?);

// Two datasets and both kinds: four streams, one connection.
let streams = DynamicStreams::init_with(&subscribers, [[
    (ExchangeId::LseCrypto, "btc", "usd", MarketDataInstrumentKind::Spot, SubKind::PublicTrades),
    (ExchangeId::LseCrypto, "btc", "usd", MarketDataInstrumentKind::Spot, SubKind::OrderBooksL1),
    (ExchangeId::LseEquities, "aapl", "usd", MarketDataInstrumentKind::Spot, SubKind::PublicTrades),
    (ExchangeId::LseEquities, "aapl", "usd", MarketDataInstrumentKind::Spot, SubKind::OrderBooksL1),
]])
.await?;

Trait Implementations

impl Clone for DynamicSubscribers

fn clone(&self) -> Self

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for DynamicSubscribers

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

Formats the value using the given formatter.

impl Default for DynamicSubscribers

fn default() -> Self

Returns the “default value” for a type.