Enum SubscribeCommand 

pub enum SubscribeCommand {
    Data(SubscribeCustomData),
    Instrument(SubscribeInstrument),
    Instruments(SubscribeInstruments),
    BookDeltas(SubscribeBookDeltas),
    BookDepth(SubscribeBookDepth),
    BookSnapshots(SubscribeBookSnapshots),
    Quotes(SubscribeQuotes),
    Trades(SubscribeTrades),
    Bars(SubscribeBars),
    MarkPrices(SubscribeMarkPrices),
    IndexPrices(SubscribeIndexPrices),
    FundingRates(SubscribeFundingRates),
    InstrumentStatus(SubscribeInstrumentStatus),
    InstrumentClose(SubscribeInstrumentClose),
    OptionGreeks(SubscribeOptionGreeks),
    OptionChain(SubscribeOptionChain),
}

Variants

Data(SubscribeCustomData)

Instrument(SubscribeInstrument)

Instruments(SubscribeInstruments)

BookDeltas(SubscribeBookDeltas)

BookDepth(SubscribeBookDepth)

BookSnapshots(SubscribeBookSnapshots)

Quotes(SubscribeQuotes)

Trades(SubscribeTrades)

Bars(SubscribeBars)

MarkPrices(SubscribeMarkPrices)

IndexPrices(SubscribeIndexPrices)

FundingRates(SubscribeFundingRates)

InstrumentStatus(SubscribeInstrumentStatus)

InstrumentClose(SubscribeInstrumentClose)

OptionGreeks(SubscribeOptionGreeks)

OptionChain(SubscribeOptionChain)

Implementations

impl SubscribeCommand

pub fn validate_routing(&self, cache: &Cache) -> Result<()>

Validates list routing before subscription ownership is retained.

Errors

Returns an error if an identifier or bar list is invalid or trade routes are mixed. For non-external clients, also rejects mixed quote routes and unsupported lists with multiple IDs containing synthetic members.

pub fn instrument_ids(&self) -> Option<&[InstrumentId]>

Returns the instrument IDs for an instrument subscription, if applicable.

pub fn with_instrument_ids( &self, instrument_ids: impl IntoInstrumentIds, ) -> Option<Self>

Projects an instrument subscription onto the supplied IDs, preserving its metadata.

Panics

Panics if an instrument subscription receives an empty identifier list.

pub fn bar_types(&self) -> Option<&[BarType]>

Returns the bar types for a bar subscription, if applicable.

pub fn with_bar_types(&self, bar_types: impl IntoBarTypes) -> Option<Self>

Projects a bar subscription onto the supplied types, preserving its metadata.

Panics

Panics if a bar subscription receives an empty list.

pub fn as_any(&self) -> &dyn Any

Converts the command to a dyn Any trait object for messaging.

pub fn into_unsubscribe( self, command_id: UUID4, ts_init: UnixNanos, correlation_id: Option<UUID4>, ) -> UnsubscribeCommand

Converts this subscribe command into its matching unsubscribe command.

Preserves the subscribed data identity and client route while replacing the command ID and initialization timestamp. It also preserves parameters and sets the supplied correlation ID when the matching unsubscribe command supports those fields.

pub fn command_id(&self) -> UUID4

pub fn client_id(&self) -> Option<&ClientId>

pub fn venue(&self) -> Option<&Venue>

pub fn ts_init(&self) -> UnixNanos

pub fn correlation_id(&self) -> Option<UUID4>

pub fn params(&self) -> Option<&Params>

Trait Implementations

impl Clone for SubscribeCommand

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 SubscribeCommand

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for SubscribeCommand

fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl PartialEq for SubscribeCommand

fn eq(&self, other: &Self) -> bool

Equality operator ==.

fn ne(&self, other: &Rhs) -> bool

Inequality operator !=.

impl Serialize for SubscribeCommand

fn serialize<__S>(&self, __serializer: __S) -> Result<__S::Ok, __S::Error>

where __S: Serializer,

Serialize this value into the given Serde serializer.