Enum nash_protocol::protocol::subscriptions::SubscriptionRequest

pub enum SubscriptionRequest {
    Trades(SubscribeTrades),
    Orderbook(SubscribeOrderbook),
}

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

Variants

Trades(SubscribeTrades)

Orderbook(SubscribeOrderbook)

Trait Implementations

impl Clone for SubscriptionRequest

pub fn clone(&self) -> SubscriptionRequest

Returns a copy of the value.

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

Performs copy-assignment from source.

impl Debug for SubscriptionRequest

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

Formats the value using the given formatter.

impl NashProtocolSubscription for SubscriptionRequest

type SubscriptionResponse = SubscriptionResponse

pub fn graphql<'life0, 'async_trait>(
    &'life0 self,
    state: Arc<Mutex<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

pub fn subscription_response_from_json<'life0, 'async_trait>(
    &'life0 self,
    response: Value,
    state: Arc<Mutex<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

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

#[must_use]pub fn process_subscription_response<'life0, 'life1, 'async_trait>(
    &'life0 self,
    _response: &'life1 Self::SubscriptionResponse,
    _state: Arc<Mutex<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