Struct async_graphql_poem::GraphQLSubscription

pub struct GraphQLSubscription<Query, Mutation, Subscription> { /* 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<Query, Mutation, Subscription> GraphQLSubscription<Query, Mutation, Subscription>

pub fn new(schema: Schema<Query, Mutation, Subscription>) -> Self

Create a GraphQL subscription endpoint.

Trait Implementations

impl<Query, Mutation, Subscription> Endpoint for GraphQLSubscription<Query, Mutation, Subscription> where
    Query: ObjectType + 'static,
    Mutation: ObjectType + 'static,
    Subscription: SubscriptionType + 'static, 

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.