Struct nash_protocol::protocol::subscriptions::trades::SubscribeTrades

pub struct SubscribeTrades {
    pub market: String,
}

Initiate subscription to get new trades

Fields

market: String

Implementations

impl SubscribeTrades

pub fn make_query(&self) -> QueryBody<Variables>

impl SubscribeTrades

pub async fn response_from_graphql(
    &self,
    response: ResponseOrError<ResponseData>,
    state: Arc<RwLock<State>>
) -> Result<ResponseOrError<TradesResponse>>

Trait Implementations

impl Clone for SubscribeTrades

fn clone(&self) -> SubscribeTrades

Returns a copy of the value.

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

Performs copy-assignment from source.

impl Debug for SubscribeTrades

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

Formats the value using the given formatter.

impl NashProtocolSubscription for SubscribeTrades

type SubscriptionResponse = TradesResponse

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