Trait graphql_ws_client::Connection

pub trait Connection {
    // Required methods
    fn receive(&mut self) -> BoxFuture<'_, Option<Message>>;
    fn send(&mut self, message: Message) -> BoxFuture<'_, Result<(), Error>>;
}

Abstrction around a websocket connection.

Built in implementations are provided for ws_stream_wasm & async_tungstenite.

If users wish to add support for a new client they should implement this trait.

Required Methods

fn receive(&mut self) -> BoxFuture<'_, Option<Message>>

Receive the next message on this connection.

fn send(&mut self, message: Message) -> BoxFuture<'_, Result<(), Error>>

Send a message with on connection

Implementors

impl Connection for Connection

Available on crate feature ws_stream_wasm only.

impl<T> Connection for T

where T: Stream<Item = Result<Message, Error>> + Sink<Message> + Send + Sync + Unpin, <T as Sink<Message>>::Error: Display,