Function async_graphql_warp::graphql_subscription_upgrade_with_data[][src]

pub async fn graphql_subscription_upgrade_with_data<Query, Mutation, Subscription, F, R, S>(
    websocket: S,
    protocol: WebSocketProtocols,
    schema: Schema<Query, Mutation, Subscription>,
    initializer: F
) where
    Query: ObjectType + 'static,
    Mutation: ObjectType + 'static,
    Subscription: SubscriptionType + 'static,
    F: FnOnce(Value) -> R + Send + 'static,
    R: Future<Output = Result<Data>> + Send + 'static,
    S: Stream<Item = Result<Message, Error>> + Sink<Message>, 
Expand description

Handle the WebSocket subscription.

Specifies that a function converts the init payload to data.