Struct async_graphql_actix_web::WSSubscription [−][src]
pub struct WSSubscription<Query, Mutation, Subscription, F> { /* fields omitted */ }
Expand description
Actor for subscription via websocket
Implementations
impl<Query, Mutation, Subscription> WSSubscription<Query, Mutation, Subscription, fn(_: Value) -> Ready<Result<Data>>> where
Query: ObjectType + 'static,
Mutation: ObjectType + 'static,
Subscription: SubscriptionType + 'static,
impl<Query, Mutation, Subscription> WSSubscription<Query, Mutation, Subscription, fn(_: Value) -> Ready<Result<Data>>> where
Query: ObjectType + 'static,
Mutation: ObjectType + 'static,
Subscription: SubscriptionType + 'static,
pub fn start<T>(
schema: Schema<Query, Mutation, Subscription>,
request: &HttpRequest,
stream: T
) -> Result<HttpResponse, Error> where
T: Stream<Item = Result<Bytes, PayloadError>> + 'static,
pub fn start<T>(
schema: Schema<Query, Mutation, Subscription>,
request: &HttpRequest,
stream: T
) -> Result<HttpResponse, Error> where
T: Stream<Item = Result<Bytes, PayloadError>> + 'static,
Start an actor for subscription connection via websocket.
impl<Query, Mutation, Subscription, F, R> WSSubscription<Query, Mutation, Subscription, F> where
Query: ObjectType + 'static,
Mutation: ObjectType + 'static,
Subscription: SubscriptionType + 'static,
F: FnOnce(Value) -> R + Unpin + Send + 'static,
R: Future<Output = Result<Data>> + Send + 'static,
impl<Query, Mutation, Subscription, F, R> WSSubscription<Query, Mutation, Subscription, F> where
Query: ObjectType + 'static,
Mutation: ObjectType + 'static,
Subscription: SubscriptionType + 'static,
F: FnOnce(Value) -> R + Unpin + Send + 'static,
R: Future<Output = Result<Data>> + Send + 'static,
pub fn start_with_initializer<T>(
schema: Schema<Query, Mutation, Subscription>,
request: &HttpRequest,
stream: T,
initializer: F
) -> Result<HttpResponse, Error> where
T: Stream<Item = Result<Bytes, PayloadError>> + 'static,
F: FnOnce(Value) -> R + Unpin + Send + 'static,
R: Future<Output = Result<Data>> + Send + 'static,
pub fn start_with_initializer<T>(
schema: Schema<Query, Mutation, Subscription>,
request: &HttpRequest,
stream: T,
initializer: F
) -> Result<HttpResponse, Error> where
T: Stream<Item = Result<Bytes, PayloadError>> + 'static,
F: FnOnce(Value) -> R + Unpin + Send + 'static,
R: Future<Output = Result<Data>> + Send + 'static,
Start an actor for subscription connection via websocket with an initialization function.
Trait Implementations
impl<Query, Mutation, Subscription, F, R> Actor for WSSubscription<Query, Mutation, Subscription, F> where
Query: ObjectType + 'static,
Mutation: ObjectType + 'static,
Subscription: SubscriptionType + 'static,
F: FnOnce(Value) -> R + Unpin + Send + 'static,
R: Future<Output = Result<Data>> + Send + 'static,
impl<Query, Mutation, Subscription, F, R> Actor for WSSubscription<Query, Mutation, Subscription, F> where
Query: ObjectType + 'static,
Mutation: ObjectType + 'static,
Subscription: SubscriptionType + 'static,
F: FnOnce(Value) -> R + Unpin + Send + 'static,
R: Future<Output = Result<Data>> + Send + 'static,
type Context = WebsocketContext<Self>
type Context = WebsocketContext<Self>
Actor execution context type
Called after an actor is in Actor::Stopping
state. Read more
Start a new asynchronous actor, returning its address. Read more
Construct and start a new asynchronous actor, returning its address. Read more
Start new actor in arbiter’s thread.
impl<Query, Mutation, Subscription, F, R> StreamHandler<Result<Message, ProtocolError>> for WSSubscription<Query, Mutation, Subscription, F> where
Query: ObjectType + 'static,
Mutation: ObjectType + 'static,
Subscription: SubscriptionType + 'static,
F: FnOnce(Value) -> R + Unpin + Send + 'static,
R: Future<Output = Result<Data>> + Send + 'static,
impl<Query, Mutation, Subscription, F, R> StreamHandler<Result<Message, ProtocolError>> for WSSubscription<Query, Mutation, Subscription, F> where
Query: ObjectType + 'static,
Mutation: ObjectType + 'static,
Subscription: SubscriptionType + 'static,
F: FnOnce(Value) -> R + Unpin + Send + 'static,
R: Future<Output = Result<Data>> + Send + 'static,
Method is called for every message received by this Actor
Method is called when stream get polled first time.
Method is called when stream finishes. Read more
fn add_stream<S>(fut: S, ctx: &mut Self::Context) -> SpawnHandle where
S: 'static + Stream<Item = I>,
I: 'static,
Self::Context: AsyncContext<Self>,
fn add_stream<S>(fut: S, ctx: &mut Self::Context) -> SpawnHandle where
S: 'static + Stream<Item = I>,
I: 'static,
Self::Context: AsyncContext<Self>,
This method register stream to an actor context and
allows to handle Stream
in similar way as normal actor messages. Read more
Auto Trait Implementations
impl<Query, Mutation, Subscription, F> !RefUnwindSafe for WSSubscription<Query, Mutation, Subscription, F>
impl<Query, Mutation, Subscription, F> Send for WSSubscription<Query, Mutation, Subscription, F> where
F: Send,
Mutation: Send + Sync,
Query: Send + Sync,
Subscription: Send + Sync,
impl<Query, Mutation, Subscription, F> Sync for WSSubscription<Query, Mutation, Subscription, F> where
F: Sync,
Mutation: Send + Sync,
Query: Send + Sync,
Subscription: Send + Sync,
impl<Query, Mutation, Subscription, F> Unpin for WSSubscription<Query, Mutation, Subscription, F> where
F: Unpin,
impl<Query, Mutation, Subscription, F> !UnwindSafe for WSSubscription<Query, Mutation, Subscription, F>
Blanket Implementations
Mutably borrows from an owned value. Read more
Instruments this type with the provided Span
, returning an
Instrumented
wrapper. Read more
pub fn vzip(self) -> V
Attaches the provided Subscriber
to this type, returning a
WithDispatch
wrapper. Read more
Attaches the current default Subscriber
to this type, returning a
WithDispatch
wrapper. Read more