diff --git a/src/connector.rs b/src/connector.rs index 66fc065a6..b2bf235fb 100644 --- a/src/connector.rs +++ b/src/connector.rs @@ -11,7 +11,7 @@ use trust_dns_resolver::config::{ResolverConfig, ResolverOpts}; use trust_dns_resolver::system_conf::read_system_conf; use super::resolver::{HostAware, Resolver, ResolverError, ResolverFuture}; -use super::{NewService, Service}; +use super::service::{NewService, Service}; // #[derive(Fail, Debug)] #[derive(Debug)] diff --git a/src/lib.rs b/src/lib.rs index 2666e2526..fe27daaea 100644 --- a/src/lib.rs +++ b/src/lib.rs @@ -57,14 +57,9 @@ extern crate webpki; #[cfg(feature = "rust-tls")] extern crate webpki_roots; -/// re-export for convinience -pub use tower_service::{NewService, Service}; - pub mod connector; pub mod resolver; pub mod server; pub mod service; pub mod ssl; pub mod stream; - -pub use service::{IntoNewService, IntoService, NewServiceExt, ServiceExt}; diff --git a/src/resolver.rs b/src/resolver.rs index 0ad3c6864..4606b1e53 100644 --- a/src/resolver.rs +++ b/src/resolver.rs @@ -11,7 +11,7 @@ use trust_dns_resolver::lookup_ip::LookupIpFuture; use trust_dns_resolver::system_conf::read_system_conf; use trust_dns_resolver::{AsyncResolver, Background}; -use super::Service; +use super::service::Service; #[derive(Debug)] pub enum ResolverError { diff --git a/src/server/mod.rs b/src/server/mod.rs index 44923cd4b..fb65b430a 100644 --- a/src/server/mod.rs +++ b/src/server/mod.rs @@ -10,6 +10,7 @@ mod worker; pub use self::server::Server; pub use self::services::ServerServiceFactory; +#[allow(unused_imports)] pub(crate) use self::worker::{Connections, ConnectionsGuard}; /// Pause accepting incoming connections diff --git a/src/server/services.rs b/src/server/services.rs index b83459d4f..459a34478 100644 --- a/src/server/services.rs +++ b/src/server/services.rs @@ -5,7 +5,7 @@ use futures::{Future, Poll}; use tokio_reactor::Handle; use tokio_tcp::TcpStream; -use {NewService, Service}; +use service::{NewService, Service}; pub enum ServerMessage { Connect(net::TcpStream), diff --git a/src/service/and_then.rs b/src/service/and_then.rs index 922e10ed0..8315e52d1 100644 --- a/src/service/and_then.rs +++ b/src/service/and_then.rs @@ -2,9 +2,8 @@ use std::cell::RefCell; use std::rc::Rc; use futures::{Async, Future, Poll}; -use tower_service::{NewService, Service}; -use super::IntoNewService; +use super::{IntoNewService, NewService, Service}; /// `AndThen` service combinator pub struct AndThen { diff --git a/src/service/apply.rs b/src/service/apply.rs index d98e77c8b..e0adf0a02 100644 --- a/src/service/apply.rs +++ b/src/service/apply.rs @@ -1,7 +1,8 @@ use std::marker::PhantomData; use futures::{Async, Future, IntoFuture, Poll}; -use {IntoNewService, NewService, Service}; + +use super::{IntoNewService, NewService, Service}; /// `Apply` service combinator pub struct Apply { diff --git a/src/service/fn_service.rs b/src/service/fn_service.rs index cf3d6d850..7a4e22846 100644 --- a/src/service/fn_service.rs +++ b/src/service/fn_service.rs @@ -4,9 +4,8 @@ use futures::{ future::{ok, FutureResult}, Async, IntoFuture, Poll, }; -use tower_service::{NewService, Service}; -use super::{IntoNewService, IntoService}; +use super::{IntoNewService, IntoService, NewService, Service}; pub struct FnService where diff --git a/src/service/fn_state_service.rs b/src/service/fn_state_service.rs index 2366baa25..70f8e2053 100644 --- a/src/service/fn_state_service.rs +++ b/src/service/fn_state_service.rs @@ -1,9 +1,8 @@ use std::marker; use futures::{Async, Future, IntoFuture, Poll}; -use tower_service::{NewService, Service}; -use super::IntoNewService; +use super::{IntoNewService, NewService, Service}; pub struct FnStateService where diff --git a/src/service/from_err.rs b/src/service/from_err.rs index ef5619dbe..3015cd005 100644 --- a/src/service/from_err.rs +++ b/src/service/from_err.rs @@ -1,7 +1,8 @@ use std::marker::PhantomData; use futures::{Future, Poll}; -use tower_service::Service; + +use super::Service; pub struct FromErr where diff --git a/src/service/map.rs b/src/service/map.rs index 9fa2acf6f..373205a95 100644 --- a/src/service/map.rs +++ b/src/service/map.rs @@ -1,7 +1,8 @@ use std::marker; use futures::{Async, Future, Poll}; -use {NewService, Service}; + +use super::{NewService, Service}; /// `Map` service combinator pub struct Map { diff --git a/src/service/map_err.rs b/src/service/map_err.rs index b05b635ae..db0ed5887 100644 --- a/src/service/map_err.rs +++ b/src/service/map_err.rs @@ -1,7 +1,8 @@ use std::marker; use futures::{Async, Future, Poll}; -use tower_service::{NewService, Service}; + +use super::{NewService, Service}; /// `MapErr` service combinator pub struct MapErr { diff --git a/src/service/map_init_err.rs b/src/service/map_init_err.rs index 1b5d1e1cd..e6129d29b 100644 --- a/src/service/map_init_err.rs +++ b/src/service/map_init_err.rs @@ -1,7 +1,8 @@ use std::marker; use futures::{Future, Poll}; -use tower_service::NewService; + +use super::NewService; /// `MapInitErr` service combinator pub struct MapInitErr { diff --git a/src/service/mod.rs b/src/service/mod.rs index 31d1aec4a..5ab16180e 100644 --- a/src/service/mod.rs +++ b/src/service/mod.rs @@ -1,5 +1,8 @@ use futures::{Future, IntoFuture}; +/// re-export for convinience +pub use tower_service::{NewService, Service}; + mod and_then; mod apply; mod fn_service; @@ -17,7 +20,6 @@ pub use self::from_err::FromErr; pub use self::map::{Map, MapNewService}; pub use self::map_err::{MapErr, MapErrNewService}; pub use self::map_init_err::MapInitErr; -use {NewService, Service}; pub trait ServiceExt: Service { fn apply(self, f: F) -> Apply diff --git a/src/ssl/openssl.rs b/src/ssl/openssl.rs index 057ab8450..8a84062d7 100644 --- a/src/ssl/openssl.rs +++ b/src/ssl/openssl.rs @@ -8,7 +8,7 @@ use tokio_openssl::{AcceptAsync, ConnectAsync, SslAcceptorExt, SslConnectorExt, use super::MAX_CONN_COUNTER; use connector::ConnectionInfo; use server::{Connections, ConnectionsGuard}; -use {NewService, Service}; +use service::{NewService, Service}; /// Support `SSL` connections via openssl package /// diff --git a/src/stream.rs b/src/stream.rs index f0ef120ec..1f03cab0b 100644 --- a/src/stream.rs +++ b/src/stream.rs @@ -2,7 +2,7 @@ use futures::unsync::mpsc; use futures::{Async, Future, Poll, Stream}; use tokio::executor::current_thread::spawn; -use super::{IntoService, Service}; +use super::service::{IntoService, Service}; pub struct StreamDispatcher { stream: S,