Struct async_graphql::http::WebSocket

pub struct WebSocket<S, E, OnInit> { /* private fields */ }

A GraphQL connection over websocket.

References

• subscriptions-transport-ws
• graphql-ws

Implementations

impl<S, E> WebSocket<S, E, fn(_: Value) -> Ready<Result<Data>>>

where E: Executor, S: Stream<Item = Result<ClientMessage>>,

pub fn from_message_stream(executor: E, stream: S, protocol: Protocols) -> Self

Create a new websocket from ClientMessage stream.

impl<S, E> WebSocket<Map<S, fn(_: <S as Stream>::Item) -> Result<ClientMessage>>, E, fn(_: Value) -> Ready<Result<Data>>>

where E: Executor, S: Stream, S::Item: AsRef<[u8]>,

pub fn new(executor: E, stream: S, protocol: Protocols) -> Self

Create a new websocket from bytes stream.

impl<S, E, OnInit> WebSocket<S, E, OnInit>

where E: Executor, S: Stream<Item = Result<ClientMessage>>,

pub fn connection_data(self, data: Data) -> Self

Specify a connection data.

This data usually comes from HTTP requests. When the GQL_CONNECTION_INIT message is received, this data will be merged with the data returned by the closure specified by with_initializer into the final subscription context data.

pub fn on_connection_init<F, R>(self, callback: F) -> WebSocket<S, E, F>

where F: FnOnce(Value) -> R + Send + 'static, R: Future<Output = Result<Data>> + Send + 'static,

Specify a connection initialize callback function.

This function if present, will be called with the data sent by the client in the GQL_CONNECTION_INIT message. From that point on the returned data will be accessible to all requests.

Trait Implementations

impl<S, E, OnInit, InitFut> Stream for WebSocket<S, E, OnInit>

where E: Executor, S: Stream<Item = Result<ClientMessage>>, OnInit: FnOnce(Value) -> InitFut + Send + 'static, InitFut: Future<Output = Result<Data>> + Send + 'static,

type Item = WsMessage

Values yielded by the stream.

fn poll_next( self: Pin<&mut Self>, cx: &mut Context<'_>, ) -> Poll<Option<Self::Item>>

Attempt to pull out the next value of this stream, registering the current task for wakeup if the value is not yet available, and returning None if the stream is exhausted.

fn size_hint(&self) -> (usize, Option<usize>)

Returns the bounds on the remaining length of the stream.

impl<'__pin, S, E, OnInit> Unpin for WebSocket<S, E, OnInit>

where PinnedFieldsOf<__Origin<'__pin, S, E, OnInit>>: Unpin,