Enum nash_protocol::protocol::subscriptions::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)

Tuple Fields of Trades

0: SubscribeTrades

Ticker(SubscribeTicker)

Tuple Fields of Ticker

0: SubscribeTicker

Orderbook(SubscribeOrderbook)

Tuple Fields of Orderbook

0: SubscribeOrderbook

AccountTrades(SubscribeAccountTrades)

Tuple Fields of AccountTrades

0: SubscribeAccountTrades

AccountOrders(SubscribeAccountOrders)

Tuple Fields of AccountOrders

0: SubscribeAccountOrders

AccountBalances(SubscribeAccountBalances)

Tuple Fields of AccountBalances

0: SubscribeAccountBalances

Trait Implementations

impl Clone for SubscriptionRequest

fn clone(&self) -> SubscriptionRequest

Returns a copy 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

Performs the conversion.

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
    'life0: 'async_trait,
    Self: '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
    'life0: 'async_trait,
    Self: '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
    'life0: 'async_trait,
    Self: '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
    'life0: 'async_trait,
    'life1: 'async_trait,
    Self: Sync + 'async_trait, 

Update state based on data from incoming subscription response