Struct SubscriptionSet 

pub struct SubscriptionSet { /* private fields */ }

Declarative subscription request — built up fluently, consumed by crate::Station::subscribe.

Implementations

impl SubscriptionSet

pub fn new() -> Self

pub fn add( self, exchange: ExchangeId, symbol: impl Into<String>, account_type: AccountType, streams: impl IntoIterator<Item = Stream>, ) -> Self

Add a subscription. symbol is canonical (e.g. "BTC-USDT", "BTCUSDT", "BTC/USDT") — it is parsed into a canonical Symbol and translated to the exchange-native form via SymbolNormalizer. Use Self::add_raw for instrument IDs that don’t fit the canonical BASE-QUOTE shape (Deribit options, exchange-specific futures suffixes, etc.).

pub fn add_raw( self, exchange: ExchangeId, symbol: impl Into<String>, account_type: AccountType, streams: impl IntoIterator<Item = Stream>, ) -> Self

Add a subscription with a raw exchange-native symbol. symbol is passed through to the connector verbatim — no SymbolNormalizer translation. Use for instrument IDs that don’t fit the canonical BASE-QUOTE shape:

• Deribit options: "BTC-23MAY26-86000-C"
• Futures with date suffix: "BTCUSDT_240329"
• Index symbols: ".DEFI", "BTCUSD-PERP"

The caller is responsible for using the exact wire format the exchange expects — Event.symbol on the handle will mirror the raw string back.

pub fn len(&self) -> usize

pub fn is_empty(&self) -> bool

Trait Implementations

impl Clone for SubscriptionSet

fn clone(&self) -> SubscriptionSet

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for SubscriptionSet

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

Formats the value using the given formatter.

impl Default for SubscriptionSet

fn default() -> SubscriptionSet

Returns the “default value” for a type.