[−][src]Struct juniper_subscriptions::Coordinator

pub struct Coordinator<'a, QueryT, MutationT, SubscriptionT, CtxT, S> where
    QueryT: GraphQLTypeAsync<S, Context = CtxT> + Send,
    QueryT::TypeInfo: Send + Sync,
    MutationT: GraphQLTypeAsync<S, Context = CtxT> + Send,
    MutationT::TypeInfo: Send + Sync,
    SubscriptionT: GraphQLSubscriptionType<S, Context = CtxT> + Send,
    SubscriptionT::TypeInfo: Send + Sync,
    CtxT: Sync,
    S: ScalarValue + Send + Sync,  { /* fields omitted */ }

Simple SubscriptionCoordinator implementation:

contains the schema
handles subscription start

Implementations

`impl<'a, QueryT, MutationT, SubscriptionT, CtxT, S> Coordinator<'a, QueryT, MutationT, SubscriptionT, CtxT, S> where QueryT: GraphQLTypeAsync<S, Context = CtxT> + Send, QueryT::TypeInfo: Send + Sync, MutationT: GraphQLTypeAsync<S, Context = CtxT> + Send, MutationT::TypeInfo: Send + Sync, SubscriptionT: GraphQLSubscriptionType<S, Context = CtxT> + Send, SubscriptionT::TypeInfo: Send + Sync, CtxT: Sync, S: ScalarValue + Send + Sync,` [src]

`pub fn new(root_node: RootNode<'a, QueryT, MutationT, SubscriptionT, S>) -> Self`[src]

Builds new Coordinator with specified root_node

Trait Implementations

impl<'a, QueryT, MutationT, SubscriptionT, CtxT, S> SubscriptionCoordinator<'a, CtxT, S> for Coordinator<'a, QueryT, MutationT, SubscriptionT, CtxT, S> where QueryT: GraphQLTypeAsync<S, Context = CtxT> + Send, QueryT::TypeInfo: Send + Sync, MutationT: GraphQLTypeAsync<S, Context = CtxT> + Send, MutationT::TypeInfo: Send + Sync, SubscriptionT: GraphQLSubscriptionType<S, Context = CtxT> + Send, SubscriptionT::TypeInfo: Send + Sync, CtxT: Sync, S: ScalarValue + Send + Sync + 'a, [src]

`type Connection = Connection<'a, S>`

Type of SubscriptionConnections this SubscriptionCoordinator returns Read more

`type Error = GraphQLError<'a>`

Type of error while trying to spawn SubscriptionConnection

`pub fn subscribe( &'a self, req: &'a GraphQLRequest<S>, context: &'a CtxT ) -> BoxFuture<'a, Result<Self::Connection, Self::Error>>`[src]

Auto Trait Implementations

`impl<'a, QueryT, MutationT, SubscriptionT, CtxT, S> RefUnwindSafe for Coordinator<'a, QueryT, MutationT, SubscriptionT, CtxT, S> where MutationT: RefUnwindSafe, QueryT: RefUnwindSafe, S: RefUnwindSafe, SubscriptionT: RefUnwindSafe, <MutationT as GraphQLValue<S>>::TypeInfo: RefUnwindSafe, <QueryT as GraphQLValue<S>>::TypeInfo: RefUnwindSafe, <SubscriptionT as GraphQLValue<S>>::TypeInfo: RefUnwindSafe,`

`impl<'a, QueryT, MutationT, SubscriptionT, CtxT, S> Send for Coordinator<'a, QueryT, MutationT, SubscriptionT, CtxT, S>`

`impl<'a, QueryT, MutationT, SubscriptionT, CtxT, S> Sync for Coordinator<'a, QueryT, MutationT, SubscriptionT, CtxT, S>`

`impl<'a, QueryT, MutationT, SubscriptionT, CtxT, S> Unpin for Coordinator<'a, QueryT, MutationT, SubscriptionT, CtxT, S> where MutationT: Unpin, QueryT: Unpin, S: Unpin, SubscriptionT: Unpin, <MutationT as GraphQLValue<S>>::TypeInfo: Unpin, <QueryT as GraphQLValue<S>>::TypeInfo: Unpin, <SubscriptionT as GraphQLValue<S>>::TypeInfo: Unpin,`

`impl<'a, QueryT, MutationT, SubscriptionT, CtxT, S> UnwindSafe for Coordinator<'a, QueryT, MutationT, SubscriptionT, CtxT, S> where MutationT: UnwindSafe, QueryT: UnwindSafe, S: UnwindSafe, SubscriptionT: UnwindSafe, <MutationT as GraphQLValue<S>>::TypeInfo: UnwindSafe, <QueryT as GraphQLValue<S>>::TypeInfo: UnwindSafe, <SubscriptionT as GraphQLValue<S>>::TypeInfo: UnwindSafe,`

Blanket Implementations

`impl<T> Any for T where T: 'static + ?Sized,` [src]

`pub fn type_id(&self) -> TypeId`[src]

`impl<T> Borrow<T> for T where T: ?Sized,` [src]

`pub fn borrow(&self) -> &T`[src]

`impl<T> BorrowMut<T> for T where T: ?Sized,` [src]

`pub fn borrow_mut(&mut self) -> &mut T`[src]

`impl<T> From<T> for T`[src]

`pub fn from(t: T) -> T`[src]

`impl<T, U> Into for T where U: From<T>,` [src]

`pub fn into(self) -> U`[src]

`impl<T, U> TryFrom for T where U: Into<T>,` [src]

`type Error = Infallible`

The type returned in the event of a conversion error.

`pub fn try_from(value: U) -> Result<T, <T as TryFrom>::Error>`[src]

`impl<T, U> TryInto for T where U: TryFrom<T>,` [src]

`type Error = >::Error`

The type returned in the event of a conversion error.

`pub fn try_into(self) -> Result<U, >::Error>`[src]

[−][src]Struct juniper_subscriptions::Coordinator

Implementations

`pub fn new(root_node: RootNode<'a, QueryT, MutationT, SubscriptionT, S>) -> Self`[src]

Trait Implementations

`type Connection = Connection<'a, S>`

`type Error = GraphQLError<'a>`

Auto Trait Implementations

`impl<'a, QueryT, MutationT, SubscriptionT, CtxT, S> Send for Coordinator<'a, QueryT, MutationT, SubscriptionT, CtxT, S>`

`impl<'a, QueryT, MutationT, SubscriptionT, CtxT, S> Sync for Coordinator<'a, QueryT, MutationT, SubscriptionT, CtxT, S>`

Blanket Implementations

`impl<T> Any for T where T: 'static + ?Sized,` [src]

`pub fn type_id(&self) -> TypeId`[src]

`impl<T> Borrow<T> for T where T: ?Sized,` [src]

`pub fn borrow(&self) -> &T`[src]

`impl<T> BorrowMut<T> for T where T: ?Sized,` [src]

`pub fn borrow_mut(&mut self) -> &mut T`[src]

`impl<T> From<T> for T`[src]

`pub fn from(t: T) -> T`[src]

`impl<T, U> Into<U> for T where U: From<T>,` [src]

`pub fn into(self) -> U`[src]

`impl<T, U> TryFrom<U> for T where U: Into<T>,` [src]

`type Error = Infallible`

`pub fn try_from(value: U) -> Result<T, <T as TryFrom<U>>::Error>`[src]

`impl<T, U> TryInto<U> for T where U: TryFrom<T>,` [src]

`type Error = <U as TryFrom<T>>::Error`

`pub fn try_into(self) -> Result<U, <U as TryFrom<T>>::Error>`[src]

[−][src]Struct juniper_subscriptions::Coordinator

Implementations

pub fn new(root_node: RootNode<'a, QueryT, MutationT, SubscriptionT, S>) -> Self[src]

Trait Implementations

type Connection = Connection<'a, S>

type Error = GraphQLError<'a>

pub fn subscribe( &'a self, req: &'a GraphQLRequest<S>, context: &'a CtxT) -> BoxFuture<'a, Result<Self::Connection, Self::Error>>[src]

Auto Trait Implementations

impl<'a, QueryT, MutationT, SubscriptionT, CtxT, S> Send for Coordinator<'a, QueryT, MutationT, SubscriptionT, CtxT, S>

impl<'a, QueryT, MutationT, SubscriptionT, CtxT, S> Sync for Coordinator<'a, QueryT, MutationT, SubscriptionT, CtxT, S>

Blanket Implementations

impl<T> Any for T where T: 'static + ?Sized, [src]

pub fn type_id(&self) -> TypeId[src]

impl<T> Borrow<T> for T where T: ?Sized, [src]

pub fn borrow(&self) -> &T[src]

impl<T> BorrowMut<T> for T where T: ?Sized, [src]

pub fn borrow_mut(&mut self) -> &mut T[src]

impl<T> From<T> for T[src]

pub fn from(t: T) -> T[src]

impl<T, U> Into<U> for T where U: From<T>, [src]

pub fn into(self) -> U[src]

impl<T, U> TryFrom<U> for T where U: Into<T>, [src]

type Error = Infallible

pub fn try_from(value: U) -> Result<T, <T as TryFrom<U>>::Error>[src]

impl<T, U> TryInto<U> for T where U: TryFrom<T>, [src]

type Error = <U as TryFrom<T>>::Error

pub fn try_into(self) -> Result<U, <U as TryFrom<T>>::Error>[src]

`pub fn new(root_node: RootNode<'a, QueryT, MutationT, SubscriptionT, S>) -> Self`[src]

`type Connection = Connection<'a, S>`

`type Error = GraphQLError<'a>`

`pub fn subscribe( &'a self, req: &'a GraphQLRequest<S>, context: &'a CtxT ) -> BoxFuture<'a, Result<Self::Connection, Self::Error>>`[src]

`impl<'a, QueryT, MutationT, SubscriptionT, CtxT, S> Send for Coordinator<'a, QueryT, MutationT, SubscriptionT, CtxT, S>`

`impl<'a, QueryT, MutationT, SubscriptionT, CtxT, S> Sync for Coordinator<'a, QueryT, MutationT, SubscriptionT, CtxT, S>`

`impl<T> Any for T where T: 'static + ?Sized,` [src]

`pub fn type_id(&self) -> TypeId`[src]

`impl<T> Borrow<T> for T where T: ?Sized,` [src]

`pub fn borrow(&self) -> &T`[src]

`impl<T> BorrowMut<T> for T where T: ?Sized,` [src]

`pub fn borrow_mut(&mut self) -> &mut T`[src]

`impl<T> From<T> for T`[src]

`pub fn from(t: T) -> T`[src]

`impl<T, U> Into<U> for T where U: From<T>,` [src]

`pub fn into(self) -> U`[src]

`impl<T, U> TryFrom<U> for T where U: Into<T>,` [src]

`type Error = Infallible`

`pub fn try_from(value: U) -> Result<T, <T as TryFrom<U>>::Error>`[src]

`impl<T, U> TryInto<U> for T where U: TryFrom<T>,` [src]

`type Error = <U as TryFrom<T>>::Error`

`pub fn try_into(self) -> Result<U, <U as TryFrom<T>>::Error>`[src]