Struct graphql_ws_client::AsyncWebsocketClientBuilder

pub struct AsyncWebsocketClientBuilder<GraphqlClient, Payload = NoPayload> where
    GraphqlClient: GraphqlClient + Send + 'static,  { /* private fields */ }

A websocket client builder

Implementations

impl<GraphqlClient, Payload> AsyncWebsocketClientBuilder<GraphqlClient, Payload> where
    GraphqlClient: GraphqlClient + Send + 'static, 

pub fn new() -> Self

Constructs an AsyncWebsocketClientBuilder

pub fn payload<NewPayload: Serialize>(
    self,
    payload: NewPayload
) -> AsyncWebsocketClientBuilder<GraphqlClient, NewPayload>

Add payload to connection_init

impl<GraphqlClient, Payload> AsyncWebsocketClientBuilder<GraphqlClient, Payload> where
    GraphqlClient: GraphqlClient + Send + 'static,
    Payload: Serialize, 

pub async fn build<WsMessage>(
    self,
    websocket_stream: impl Stream<Item = Result<WsMessage, WsMessage::Error>> + Unpin + Send + 'static,
    websocket_sink: impl Sink<WsMessage, Error = WsMessage::Error> + Unpin + Send + 'static,
    runtime: impl SpawnExt
) -> Result<AsyncWebsocketClient<GraphqlClient, WsMessage>, Error> where
    GraphqlClient: GraphqlClient + Send + 'static,
    WsMessage: WebsocketMessage + Send + 'static, 

Constructs an AsyncWebsocketClient

Accepts a stream and a sink for the underlying websocket connection, and an async_executors::SpawnHandle that tells the client which async runtime to use.

Trait Implementations

impl<GraphqlClient, Payload> Default for AsyncWebsocketClientBuilder<GraphqlClient, Payload> where
    GraphqlClient: GraphqlClient + Send + 'static, 

fn default() -> Self

Returns the “default value” for a type.