Struct 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 duplicate 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 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