Merge pull request #109 from shaladdle/formatting

Run cargo fmt

benches/latency.rs

@@ -41,8 +41,8 @@ fn latency(bencher: &mut Bencher) {
     let _ = env_logger::init();
     let mut reactor = reactor::Core::new().unwrap();
     let addr = Server.listen("localhost:0".first_socket_addr(),
-                             &reactor.handle(),
-                             server::Options::default())
+                &reactor.handle(),
+                server::Options::default())
         .unwrap();
     let client = reactor.run(FutureClient::connect(addr, client::Options::default())).unwrap();
 

src/client.rs

@@ -3,9 +3,9 @@
 // Licensed under the MIT License, <LICENSE or http://opensource.org/licenses/MIT>.
 // This file may not be copied, modified, or distributed except according to those terms.
 
+use {WireError, bincode};
 #[cfg(feature = "tls")]
 use self::tls::*;
-use {WireError, bincode};
 use tokio_core::reactor;
 
 type WireResponse<Resp, E> = Result<Result<Resp, WireError<E>>, bincode::Error>;
@@ -86,7 +86,6 @@ enum Reactor {
 
 /// Exposes a trait for connecting asynchronously to servers.
 pub mod future {
-    use super::{Options, Reactor, WireResponse};
     use {REMOTE, WireError};
     #[cfg(feature = "tls")]
     use errors::native_to_io;
@@ -97,6 +96,7 @@ pub mod future {
     use std::io;
     use std::net::SocketAddr;
     use stream_type::StreamType;
+    use super::{Options, Reactor, WireResponse};
     use tokio_core::net::TcpStream;
     use tokio_core::reactor;
     use tokio_proto::BindClient as ProtoBindClient;
@@ -264,13 +264,13 @@ pub mod future {
 
 /// Exposes a trait for connecting synchronously to servers.
 pub mod sync {
-    use super::Options;
-    use super::Reactor;
-    use super::future::{Client as FutureClient, ClientExt as FutureClientExt};
     use serde::{Deserialize, Serialize};
     use std::fmt;
     use std::io;
     use std::net::ToSocketAddrs;
+    use super::Options;
+    use super::Reactor;
+    use super::future::{Client as FutureClient, ClientExt as FutureClientExt};
     use tokio_core::reactor;
     use tokio_service::Service;
     use util::FirstSocketAddr;

src/macros.rs

@@ -991,8 +991,8 @@ mod functional_test {
     }
 
     mod future {
-        use super::{FutureClient, FutureService, env_logger, start_server_with_async_client};
         use futures::{Finished, finished};
+        use super::{FutureClient, FutureService, env_logger, start_server_with_async_client};
         use tokio_core::reactor;
         use util::Never;