1.3 KiB
1.3 KiB
Warp
Async-graphql-warp
提供了两个Filter
,graphql
和graphql_subscription
。
graphql
用于执行Query
和Mutation
请求,他总是要求POST方法,输出一个包含async_graphql::Schema
和async_graphql::Request的元组
,你可以在之后组合其它Filter,或者直接调用Schema::execute
执行查询。
graphql_subscription
用于实现基于Web Socket的订阅,它输出warp::Reply
。
请求例子
type MySchema = Schema<QueryRoot, EmptyMutation, EmptySubscription>;
let schema = Schema::new(QueryRoot, EmptyMutation, EmptySubscription);
let filter = async_graphql_warp::graphql(schema).and_then(|(schema, request): (MySchema, async_graphql::Request)| async move {
// 执行查询
let resp = schema.execute(request).await;
// 返回结果
Ok::<_, Infallible>(async_graphql_warp::Response::from(resp))
});
warp::serve(filter).run(([0, 0, 0, 0], 8000)).await;
订阅例子
let schema = Schema::new(QueryRoot, EmptyMutation, SubscriptionRoot);
let filter = async_graphql_warp::graphql_subscription(schema);
warp::serve(filter).run(([0, 0, 0, 0], 8000)).await;