*: Run fmt

benches/lines.rs

@@ -2,8 +2,8 @@
 
 extern crate test;
 
-use futures::{executor, io::Cursor, TryStreamExt};
 use asynchronous_codec::{FramedRead, LinesCodec};
+use futures::{executor, io::Cursor, TryStreamExt};
 
 #[bench]
 fn short(b: &mut test::Bencher) {

src/codec/json.rs

@@ -153,7 +153,6 @@ where
     }
 }
 
-
 impl<Enc, Dec> Default for JsonCodec<Enc, Dec>
 where
     for<'de> Dec: Deserialize<'de> + 'static,
@@ -164,7 +163,6 @@ where
     }
 }
 
-
 #[cfg(test)]
 mod test {
     use bytes::BytesMut;

tests/bytes.rs

@@ -1,6 +1,6 @@
+use asynchronous_codec::{BytesCodec, Framed};
 use futures::io::Cursor;
 use futures::{executor, TryStreamExt};
-use asynchronous_codec::{BytesCodec, Framed};
 
 #[test]
 fn decodes() {

tests/framed_read.rs

@@ -1,7 +1,7 @@
+use asynchronous_codec::{BytesMut, Decoder, FramedRead, LinesCodec};
 use futures::executor;
 use futures::stream::StreamExt;
 use futures::AsyncRead;
-use asynchronous_codec::{BytesMut, Decoder, FramedRead, LinesCodec};
 use std::io;
 use std::pin::Pin;
 use std::task::{Context, Poll};

tests/framed_write.rs

@@ -1,8 +1,8 @@
+use asynchronous_codec::{Bytes, BytesCodec, FramedWrite, LinesCodec};
 use core::iter::Iterator;
 use futures::io::{AsyncWrite, Cursor};
 use futures::sink::SinkExt;
 use futures::{executor, stream, stream::StreamExt};
-use asynchronous_codec::{Bytes, BytesCodec, FramedWrite, LinesCodec};
 use std::pin::Pin;
 use std::task::{Context, Poll};
 

tests/length_delimited.rs

@@ -1,6 +1,6 @@
+use asynchronous_codec::{Bytes, Framed, LengthCodec};
 use futures::io::Cursor;
 use futures::{executor, SinkExt, StreamExt};
-use asynchronous_codec::{Bytes, Framed, LengthCodec};
 
 #[test]
 fn same_msgs_are_received_as_were_sent() {

tests/lines.rs

@@ -1,6 +1,6 @@
+use asynchronous_codec::{FramedRead, LinesCodec};
 use futures::io::Cursor;
 use futures::{executor, TryStreamExt};
-use asynchronous_codec::{FramedRead, LinesCodec};
 
 #[test]
 fn it_works() {