Enum SubscriptionRequest 

pub enum SubscriptionRequest {
    Trades(SubscribeTrades),
    Ticker(SubscribeTicker),
    Orderbook(SubscribeOrderbook),
    AccountTrades(SubscribeAccountTrades),
    AccountOrders(SubscribeAccountOrders),
    AccountBalances(SubscribeAccountBalances),
}

Wrapper for all subscription request types supported on Nash. Required only for current version of openlimits subscription logic

Variants

Trades(SubscribeTrades)

Ticker(SubscribeTicker)

Orderbook(SubscribeOrderbook)

AccountTrades(SubscribeAccountTrades)

AccountOrders(SubscribeAccountOrders)

AccountBalances(SubscribeAccountBalances)

Trait Implementations

impl Clone for SubscriptionRequest

fn clone(&self) -> SubscriptionRequest

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for SubscriptionRequest

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

Formats the value using the given formatter.

impl From<Subscription> for SubscriptionRequest

fn from(sub: Subscription) -> Self

Converts to this type from the input type.

impl NashProtocolSubscription for SubscriptionRequest

type SubscriptionResponse = SubscriptionResponse

fn graphql<'life0, 'async_trait>( &'life0 self, state: Arc<RwLock<State>>, ) -> Pin<Box<dyn Future<Output = Result<Value>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Convert the protocol request to GraphQL from communication with Nash server

fn subscription_response_from_json<'life0, 'async_trait>( &'life0 self, response: Value, state: Arc<RwLock<State>>, ) -> Pin<Box<dyn Future<Output = Result<ResponseOrError<Self::SubscriptionResponse>>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Convert JSON response from incoming subscription data into protocol’s associated type

fn wrap_response_as_any_subscription<'life0, 'async_trait>( &'life0 self, response: Value, state: Arc<RwLock<State>>, ) -> Pin<Box<dyn Future<Output = Result<ResponseOrError<SubscriptionResponse>>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

fn process_subscription_response<'life0, 'life1, 'async_trait>( &'life0 self, _response: &'life1 Self::SubscriptionResponse, _state: Arc<RwLock<State>>, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

where Self: Sync + 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Update state based on data from incoming subscription response