pub fn start<T>(
        schema: Schema<Query, Mutation, Subscription>,
        request: &HttpRequest,
        stream: T,
    ) -> Result<HttpResponse, Error>
    where
        T: Stream<Item = Result<Bytes, PayloadError>> + 'static,
    {
        Self::start_with_initializer(schema, request, stream, |_| {
            futures_util::future::ready(Ok(Default::default()))
        })
    }
/// Start an actor for subscription connection via websocket.
Start an actor for subscription connection via websocket.
Start an actor for subscription connection via websocket .
pub fn start<T>(
        schema: Schema<Query, Mutation, Subscription>,
        request: &HttpRequest,
        stream: T,
    ) -> Result<HttpResponse, Error>
    where
        T: Stream<Item = Result<Bytes, PayloadError>> + 'static,
    {
        Self::start_with_initializer(schema, request, stream, |_| {
            futures_util::future::ready(Ok(Default::default()))
        })
    }
pub fn start < T > ( schema : Schema < Query , Mutation , Subscription > , request : & HttpRequest , stream : T , ) -> Result < HttpResponse , Error > where T : Stream < Item = Result < Bytes , PayloadError > > + ' static , { Self :: start_with_initializer ( schema , request , stream , | _ | { futures_util :: future :: ready ( Ok ( Default :: default ( ) ) ) } ) }
Start an actor for subscription connection via websocket.
Start an actor for subscription connection via websocket .
schema
Schema<Query, Mutation, Subscription>
request
&HttpRequest
stream
T
schema
Schema<Query, Mutation, Subscription>
request
&HttpRequest
stream
T