cargo fmt

Author: vi

src/client/builder.rs

@@ -1,7 +1,9 @@
 //! Everything you need to create a client connection to a websocket.
 
 use crate::header::extensions::Extension;
-use crate::header::{Origin, WebSocketExtensions, WebSocketKey, WebSocketProtocol, WebSocketVersion};
+use crate::header::{
+	Origin, WebSocketExtensions, WebSocketKey, WebSocketProtocol, WebSocketVersion,
+};
 use hyper::header::{Authorization, Basic, Header, HeaderFormat, Headers};
 use hyper::version::HttpVersion;
 use std::borrow::Cow;
@@ -11,6 +13,8 @@ pub use url::{ParseError, Url};
 #[cfg(any(feature = "sync", feature = "async"))]
 mod common_imports {
 	pub use crate::header::WebSocketAccept;
+	pub use crate::result::{WSUrlErrorKind, WebSocketError, WebSocketOtherError, WebSocketResult};
+	pub use crate::stream::{self, Stream};
 	pub use hyper::buffer::BufReader;
 	pub use hyper::header::{Connection, ConnectionOption, Host, Protocol, ProtocolName, Upgrade};
 	pub use hyper::http::h1::parse_response;
@@ -19,10 +23,8 @@ mod common_imports {
 	pub use hyper::method::Method;
 	pub use hyper::status::StatusCode;
 	pub use hyper::uri::RequestUri;
-	pub use crate::result::{WSUrlErrorKind, WebSocketError, WebSocketOtherError, WebSocketResult};
 	pub use std::net::TcpStream;
 	pub use std::net::ToSocketAddrs;
-	pub use crate::stream::{self, Stream};
 	pub use unicase::UniCase;
 	pub use url::Position;
 }
@@ -44,6 +46,7 @@ use native_tls::TlsStream;
 mod async_imports {
 	pub use super::super::r#async;
 	pub use crate::codec::ws::{Context, MessageCodec};
+	pub use crate::ws::util::update_framed_codec;
 	pub use futures::future;
 	pub use futures::Stream as FutureStream;
 	pub use futures::{Future, IntoFuture, Sink};
@@ -53,7 +56,6 @@ mod async_imports {
 	pub use tokio_tcp::TcpStream as TcpStreamNew;
 	#[cfg(feature = "async-ssl")]
 	pub use tokio_tls::TlsConnector as TlsConnectorExt;
-	pub use crate::ws::util::update_framed_codec;
 }
 #[cfg(feature = "async")]
 use self::async_imports::*;

src/codec/http.rs

@@ -255,11 +255,11 @@ impl From<hyper::Error> for HttpCodecError {
 #[cfg(test)]
 mod tests {
 	use super::*;
+	use crate::stream::ReadWritePair;
 	use futures::{Future, Sink, Stream};
 	use hyper::header::Headers;
 	use hyper::version::HttpVersion;
 	use std::io::Cursor;
-	use crate::stream::ReadWritePair;
 	use tokio::runtime::current_thread::Builder;
 
 	#[test]

src/header/accept.rs

@@ -1,8 +1,8 @@
 use crate::header::WebSocketKey;
+use crate::result::{WebSocketError, WebSocketResult};
 use hyper;
 use hyper::header::parsing::from_one_raw_str;
 use hyper::header::{Header, HeaderFormat};
-use crate::result::{WebSocketError, WebSocketResult};
 use std::fmt::{self, Debug};
 use std::str::FromStr;
 

src/header/extensions.rs

@@ -1,9 +1,9 @@
 //! Provides the Sec-WebSocket-Extensions header.
 
+use crate::result::{WebSocketError, WebSocketResult};
 use hyper;
 use hyper::header::parsing::{fmt_comma_delimited, from_comma_delimited};
 use hyper::header::{Header, HeaderFormat};
-use crate::result::{WebSocketError, WebSocketResult};
 use std::fmt;
 use std::ops::Deref;
 use std::str::FromStr;

src/header/key.rs

@@ -1,7 +1,7 @@
+use crate::result::{WebSocketError, WebSocketResult};
 use hyper;
 use hyper::header::parsing::from_one_raw_str;
 use hyper::header::{Header, HeaderFormat};
-use crate::result::{WebSocketError, WebSocketResult};
 use std::fmt::{self, Debug};
 use std::str::FromStr;
 

src/lib.rs

@@ -4,7 +4,7 @@
 	clippy::write_with_newline,
 	clippy::type_complexity,
 	clippy::match_ref_pats,
-	clippy::needless_doctest_main,
+	clippy::needless_doctest_main
 )]
 #![deny(unused_mut)]
 
@@ -142,8 +142,8 @@ pub mod r#async {
 
 	/// A collection of handy asynchronous-only parts of the `client` module.
 	pub mod client {
-		pub use crate::client::r#async::*;
 		pub use crate::client::builder::ClientBuilder;
+		pub use crate::client::r#async::*;
 	}
 	pub use crate::client::r#async::Client;
 

src/result.rs

@@ -1,8 +1,8 @@
 //! The result type used within Rust-WebSocket
 
+use crate::server::upgrade::HyperIntoWsError;
 pub use hyper::status::StatusCode;
 use hyper::Error as HttpError;
-use crate::server::upgrade::HyperIntoWsError;
 use std::convert::From;
 use std::error::Error;
 use std::fmt;

src/sender.rs

@@ -1,13 +1,13 @@
 //! The default implementation of a WebSocket Sender.
 
 use crate::result::WebSocketResult;
-use std::io::Result as IoResult;
-use std::io::Write;
 use crate::stream::sync::AsTcpStream;
 pub use crate::stream::sync::Shutdown;
 use crate::ws;
 use crate::ws::dataframe::DataFrame;
 use crate::ws::sender::Sender as SenderTrait;
+use std::io::Result as IoResult;
+use std::io::Write;
 
 /// A writer that bundles a stream with a serializer to send the messages.
 /// This is used in the client's `.split()` function as the writing component.

src/server/async.rs

@@ -1,10 +1,10 @@
 //! The asynchronous implementation of a websocket server.
-use bytes::BytesMut;
-use futures;
-use futures::{Future, Stream};
 use crate::server::upgrade::r#async::{IntoWs, Upgrade};
 use crate::server::InvalidConnection;
 use crate::server::{NoTlsAcceptor, OptionalTlsAcceptor, WsServer};
+use bytes::BytesMut;
+use futures;
+use futures::{Future, Stream};
 use std;
 use std::io;
 use std::net::SocketAddr;

src/server/mod.rs

@@ -3,8 +3,8 @@
 use native_tls::TlsAcceptor;
 
 use self::upgrade::{HyperIntoWsError, Request};
-use std::fmt::{Debug, Formatter, Result as FmtResult};
 use crate::stream::Stream;
+use std::fmt::{Debug, Formatter, Result as FmtResult};
 
 pub mod upgrade;