yume/juniper
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

Fmt juniper_actix crate

Browse source
This commit is contained in:
tyranron 2020-09-02 22:52:15 +03:00
parent a684e1d91c
commit 0f400c3799
No known key found for this signature in database
GPG key ID: 762E144FB230A4F0
1 changed files with 15 additions and 9 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

20
juniper_actix/src/lib.rs
View file

@ -227,19 +227,22 @@ pub async fn playground_handler(
pub mod subscriptions { pub mod subscriptions {
use std::{fmt, sync::Arc}; use std::{fmt, sync::Arc};
use actix::prelude::*; use actix::{prelude::*, Actor, StreamHandler};
use actix::{Actor, StreamHandler}; use actix_web::{
use actix_web::http::header::{HeaderName, HeaderValue}; http::header::{HeaderName, HeaderValue},
use actix_web::{web, HttpRequest, HttpResponse}; web, HttpRequest, HttpResponse,
};
use actix_web_actors::ws; use actix_web_actors::ws;
use tokio::sync::Mutex; use tokio::sync::Mutex;
use juniper::futures::{ use juniper::{
futures::{
stream::{SplitSink, SplitStream, StreamExt}, stream::{SplitSink, SplitStream, StreamExt},
SinkExt, SinkExt,
},
GraphQLSubscriptionType, GraphQLTypeAsync, RootNode, ScalarValue,
}; };
use juniper::{GraphQLSubscriptionType, GraphQLTypeAsync, RootNode, ScalarValue};
use juniper_graphql_ws::{ArcSchema, ClientMessage, Connection, Init, ServerMessage}; use juniper_graphql_ws::{ArcSchema, ClientMessage, Connection, Init, ServerMessage};
/// Serves the graphql-ws protocol over a WebSocket connection. /// Serves the graphql-ws protocol over a WebSocket connection.
@ -782,7 +785,10 @@ mod subscription_tests {
use juniper::{ use juniper::{
futures::{SinkExt, StreamExt}, futures::{SinkExt, StreamExt},
http::tests::{run_ws_test_suite, WsIntegration, WsIntegrationMessage}, http::tests::{run_ws_test_suite, WsIntegration, WsIntegrationMessage},
tests::fixtures::starwars::{model::Database, schema::Query, schema::Subscription}, tests::fixtures::starwars::{
model::Database,
schema::{Query, Subscription},
},
EmptyMutation, LocalBoxFuture, EmptyMutation, LocalBoxFuture,
}; };
use juniper_graphql_ws::ConnectionConfig; use juniper_graphql_ws::ConnectionConfig;