Struct Connection 

pub struct Connection { /* private fields */ }

Connect to glimesh over websockets

Implementations

impl Connection

pub fn builder() -> ConnectionBuilder

Create a ConnectionBuilder to configure various options.

pub async fn connect(auth: Auth) -> Result<Self, WebsocketConnectionError>

Create a connection with the default options.

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

Create a client with reference to this connection

pub fn to_client(&self) -> WebsocketClient

Create a client with a clone of this connection

pub fn into_client(self) -> WebsocketClient

Convert this connection into a client

pub fn close(self)

Terminate the socket connection

Trait Implementations

impl Clone for Connection

fn clone(&self) -> Connection

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for Connection

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

Formats the value using the given formatter.

impl MutationConn for Connection

type Error = WebsocketConnectionError

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 QueryConn for Connection

type Error = WebsocketConnectionError

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 SubscriptionConn for Connection

type Error = WebsocketConnectionError

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