Struct async_graphql::WebSocketTransport

pub struct WebSocketTransport { /* fields omitted */ }

WebSocket transport

Methods

impl WebSocketTransport

pub fn new<F: Fn(Value) -> Data + Send + Sync + 'static>(
    init_with_payload: F
) -> Self

Creates a websocket transport and sets the function that converts the payload of the connect_init message to Data.

Trait Implementations

impl Default for WebSocketTransport

fn default() -> WebSocketTransport

Returns the "default value" for a type.

impl SubscriptionTransport for WebSocketTransport

type Error = String

The error type.

fn handle_request<'life0, 'life1, 'life2, 'async_trait, Query, Mutation, Subscription>(
    &'life0 mut self,
    schema: &'life1 Schema<Query, Mutation, Subscription>,
    streams: &'life2 mut SubscriptionStreams,
    data: Bytes
) -> Pin<Box<dyn Future<Output = Result<Option<Bytes>, Self::Error>> + Send + 'async_trait>> where
    Query: ObjectType + Sync + Send + 'static,
    Mutation: ObjectType + Sync + Send + 'static,
    Subscription: SubscriptionType + Sync + Send + 'static,
    Query: 'async_trait,
    Mutation: 'async_trait,
    Subscription: 'async_trait,
    'life0: 'async_trait,
    'life1: 'async_trait,
    'life2: 'async_trait,
    Self: 'async_trait, 

Parse the request data here. If you have a new subscribe, create a stream with the Schema::create_subscription_stream, and then call SubscriptionStreams::add. You can return a Byte, which will be sent to the client. If it returns an error, the connection will be broken.

fn handle_response(&mut self, id: usize, value: Value) -> Option<Bytes>

When a response message is generated, you can convert the message to the format you want here.