Struct async_graphql_poem::GraphQLSubscription

pub struct GraphQLSubscription<E> { /* private fields */ }

A GraphQL subscription endpoint.

Example

use async_graphql::{EmptyMutation, Object, Schema, Subscription};
use async_graphql_poem::GraphQLSubscription;
use futures_util::{stream, Stream};
use poem::{get, Route};

struct Query;

#[Object]
impl Query {
    async fn value(&self) -> i32 {
        100
    }
}

struct Subscription;

#[Subscription]
impl Subscription {
    async fn values(&self) -> impl Stream<Item = i32> {
        stream::iter(vec![1, 2, 3, 4, 5])
    }
}

type MySchema = Schema<Query, EmptyMutation, Subscription>;

let schema = Schema::new(Query, EmptyMutation, Subscription);
let app = Route::new().at("/ws", get(GraphQLSubscription::new(schema)));

Implementations

impl<E> GraphQLSubscription<E>

pub fn new(executor: E) -> Self

Create a GraphQL subscription endpoint.

Trait Implementations

impl<E> Endpoint for GraphQLSubscription<E>where
    E: Executor,

type Output = Response

Represents the response of the endpoint.

fn call<'life0, 'async_trait>(
    &'life0 self,
    req: Request
) -> Pin<Box<dyn Future<Output = Result<Self::Output>> + Send + 'async_trait>>where
    'life0: 'async_trait,
    Self: 'async_trait,

Get the response to the request.

fn get_response<'life0, 'async_trait>(
    &'life0 self,
    req: Request
) -> Pin<Box<dyn Future<Output = Response> + Send + 'async_trait, Global>>where
    'life0: 'async_trait,
    Self: 'async_trait,

Get the response to the request and return a Response.