Struct glimesh::hybrid::Connection

pub struct Connection<C, S> { /* private fields */ }

A hybrid connection that allows combining two different connections into one effective connection, for example for using an http client for querying & mutating, and a websocket client for subscriptions.

Implementations

impl<C, S> Connection<C, S>

pub fn new(query_conn: C, subscription_conn: S) -> Self

Create a new hybrid connection. The first connection will be used for query and mutate operations, and the second only for subscriptions.

pub fn as_client(&self) -> Client<&Self>

Create a client with reference to this connection

pub fn into_client(self) -> Client<Self>

Convert this connection into a client

impl<C, S> Connection<C, S>where C: Clone, S: Clone,

pub fn to_client(&self) -> Client<Self>

Create a client with a clone of this connection

Trait Implementations

impl<C, S> Clone for Connection<C, S>where C: Clone, S: Clone,

fn clone(&self) -> Self

Returns a copy of the value.

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

Performs copy-assignment from source.

impl<C, S> Debug for Connection<C, S>

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

Formats the value using the given formatter.

impl<C, S> MutationConn for Connection<C, S>where C: MutationConn + Send + Sync, S: Send + Sync,

type Error = <C as MutationConn>::Error

Error type representing any errors that can occurr when mutating

fn mutate<'life0, 'async_trait, Q>( &'life0 self, variables: Q::Variables ) -> Pin<Box<dyn Future<Output = Result<Q::ResponseData, Self::Error>> + Send + 'async_trait>>where Q: GraphQLQuery + 'async_trait, Q::Variables: Send + Sync, Self: 'async_trait, 'life0: 'async_trait,

Send a graphql mutation over this connection.

impl<C, S> QueryConn for Connection<C, S>where C: QueryConn + Send + Sync, S: Send + Sync,

type Error = <C as QueryConn>::Error

Error type representing any errors that can occurr when querying

fn query<'life0, 'async_trait, Q>( &'life0 self, variables: Q::Variables ) -> Pin<Box<dyn Future<Output = Result<Q::ResponseData, Self::Error>> + Send + 'async_trait>>where Q: GraphQLQuery + 'async_trait, Q::Variables: Send + Sync, Self: 'async_trait, 'life0: 'async_trait,

Send a graphql query over this connection.

impl<C, S> SubscriptionConn for Connection<C, S>where S: SubscriptionConn + Send + Sync, C: Send + Sync,

type Error = <S as SubscriptionConn>::Error

Error type representing any errors that can occurr when subscribing

fn subscribe<'life0, 'async_trait, Q>( &'life0 self, variables: Q::Variables ) -> Pin<Box<dyn Future<Output = Result<Subscription<Q::ResponseData>, Self::Error>> + Send + 'async_trait>>where Q: GraphQLQuery + 'async_trait, Q::Variables: Send + Sync, Self: 'async_trait, 'life0: 'async_trait,

Send a graphql subscription over this connection. The future will resolve when the subscription has been established, and then any messages will be sent on the returned stream