Enum DefiSubscribeCommand 

pub enum DefiSubscribeCommand {
    Blocks(SubscribeBlocks),
    Pool(SubscribePool),
    PoolSwaps(SubscribePoolSwaps),
    PoolLiquidityUpdates(SubscribePoolLiquidityUpdates),
    PoolFeeCollects(SubscribePoolFeeCollects),
    PoolFlashEvents(SubscribePoolFlashEvents),
}

Variants

Blocks(SubscribeBlocks)

Pool(SubscribePool)

PoolSwaps(SubscribePoolSwaps)

PoolLiquidityUpdates(SubscribePoolLiquidityUpdates)

PoolFeeCollects(SubscribePoolFeeCollects)

PoolFlashEvents(SubscribePoolFlashEvents)

Implementations

impl DefiSubscribeCommand

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, ) -> DefiUnsubscribeCommand

Converts this subscribe command into its matching unsubscribe command.

Preserves the subscribed data identity, client route, and parameters while replacing the command ID and initialization timestamp with the supplied values.

pub fn blockchain(&self) -> Blockchain

Returns the blockchain associated with this command.

Panics

Panics if the instrument ID’s venue cannot be parsed as a valid blockchain venue for Pool, PoolSwaps, PoolLiquidityUpdates, PoolFeeCollects, or PoolFlashEvents commands.

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

Trait Implementations

impl Clone for DefiSubscribeCommand

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 DefiSubscribeCommand

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for DefiSubscribeCommand

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

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl PartialEq for DefiSubscribeCommand

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

Equality operator ==.

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

Inequality operator !=.

impl Serialize for DefiSubscribeCommand

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

where __S: Serializer,

Serialize this value into the given Serde serializer.