From 0780af9e05d17d6e1162d08b5c26fc5eed6910c9 Mon Sep 17 00:00:00 2001 From: Adam Wright Date: Sat, 18 Feb 2017 15:37:31 -0800 Subject: [PATCH] Run cargo fmt --- benches/latency.rs | 4 ++-- src/client.rs | 10 +++++----- src/macros.rs | 2 +- 3 files changed, 8 insertions(+), 8 deletions(-) diff --git a/benches/latency.rs b/benches/latency.rs index 768bd3d..3d6550f 100644 --- a/benches/latency.rs +++ b/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(); diff --git a/src/client.rs b/src/client.rs index 00543c0..450e6ed 100644 --- a/src/client.rs +++ b/src/client.rs @@ -3,9 +3,9 @@ // Licensed under the MIT License, . // 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 = Result>, 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; diff --git a/src/macros.rs b/src/macros.rs index 9c07e8e..d4f2d84 100644 --- a/src/macros.rs +++ b/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;