Struct tensor_trade_stream::graphql::subscription::SubscriptionClient

pub struct SubscriptionClient { /* private fields */ }

A single SubscriptionClient enables subscription multiplexing.

Implementations

impl SubscriptionClient

pub fn new(tx: UnboundedSender<Payload>, rx: UnboundedReceiver<Payload>) -> Self

Create a new subscription client. tx is a channel for sending Payloads to the GraphQL server; rx is a channel for Payload back.

pub fn start<T>( &self, request_body: &QueryBody<T::Variables> ) -> BoxedSubscription<T>

where T: GraphQLQuery + Send + Sync, <T as GraphQLQuery>::ResponseData: Unpin + Send + Sync + 'static,

Start a new subscription request.

Trait Implementations

impl Debug for SubscriptionClient

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

Formats the value using the given formatter.