chore(rustfmt): optimize import (#39)

Author: jjeffcaii

examples/echo.rs

@@ -1,6 +1,8 @@
 #[macro_use]
 extern crate log;
 
+use std::fs;
+
 use clap::{App, Arg, SubCommand};
 use rsocket_rust::prelude::*;
 use rsocket_rust::transport::Connection;
@@ -10,7 +12,6 @@ use rsocket_rust_transport_tcp::{
     TcpClientTransport, TcpServerTransport, UnixClientTransport, UnixServerTransport,
 };
 use rsocket_rust_transport_websocket::{WebsocketClientTransport, WebsocketServerTransport};
-use std::fs;
 
 enum RequestMode {
     FNF,

examples/qps.rs

@@ -1,17 +1,18 @@
 #[macro_use]
 extern crate log;
 
+use std::sync::{
+    atomic::{AtomicU32, Ordering},
+    Arc,
+};
+use std::time::SystemTime;
+
 use clap::{App, Arg};
 use rsocket_rust::prelude::*;
 use rsocket_rust::transport::{Connection, Transport};
 use rsocket_rust::Result;
 use rsocket_rust_transport_tcp::{TcpClientTransport, UnixClientTransport};
 use rsocket_rust_transport_websocket::WebsocketClientTransport;
-use std::sync::{
-    atomic::{AtomicU32, Ordering},
-    Arc,
-};
-use std::time::SystemTime;
 use tokio::sync::{oneshot, Notify};
 
 async fn connect<A, B>(

justfile

@@ -9,7 +9,7 @@ test:
 lint:
     @cargo clippy
 fmt:
-    @cargo fmt
+    @cargo +nightly fmt
 echo:
     @RUST_LOG=release cargo run --release --example echo -- serve tcp://127.0.0.1:7878
 bench:

rsocket-messaging/src/requester.rs

@@ -1,4 +1,7 @@
-use super::misc::{self, marshal, unmarshal};
+use std::collections::LinkedList;
+use std::net::SocketAddr;
+use std::sync::Arc;
+
 use bytes::{Bytes, BytesMut};
 use rsocket_rust::extension::{CompositeMetadata, MimeType, RoutingMetadata};
 use rsocket_rust::prelude::*;
@@ -7,11 +10,10 @@ use rsocket_rust::{error::RSocketError, Result};
 use rsocket_rust_transport_tcp::TcpClientTransport;
 use rsocket_rust_transport_websocket::WebsocketClientTransport;
 use serde::{de::DeserializeOwned, Serialize};
-use std::collections::LinkedList;
-use std::net::SocketAddr;
-use std::sync::Arc;
 use url::Url;
 
+use super::misc::{self, marshal, unmarshal};
+
 type FnMetadata = Box<dyn FnMut() -> Result<(MimeType, Vec<u8>)>>;
 type FnData = Box<dyn FnMut(&MimeType) -> Result<Vec<u8>>>;
 type PreflightResult = Result<(Payload, MimeType, Arc<Box<dyn RSocket>>)>;

rsocket-test/tests/test_clients.rs

@@ -1,6 +1,9 @@
 #[macro_use]
 extern crate log;
 
+use std::thread::sleep;
+use std::time::Duration;
+
 use futures::stream;
 use rsocket_rust::prelude::*;
 use rsocket_rust::utils::EchoRSocket;
@@ -9,8 +12,6 @@ use rsocket_rust_transport_tcp::{
     TcpClientTransport, TcpServerTransport, UnixClientTransport, UnixServerTransport,
 };
 use rsocket_rust_transport_websocket::{WebsocketClientTransport, WebsocketServerTransport};
-use std::thread::sleep;
-use std::time::Duration;
 use tokio::runtime::Runtime;
 
 fn init() {

rsocket-transport-tcp/src/client/tcp.rs

@@ -1,9 +1,11 @@
-use crate::{connection::TcpConnection, misc::parse_tcp_addr};
+use std::net::SocketAddr;
+
 use rsocket_rust::async_trait;
 use rsocket_rust::{error::RSocketError, transport::Transport, Result};
-use std::net::SocketAddr;
 use tokio::net::TcpStream;
 
+use crate::{connection::TcpConnection, misc::parse_tcp_addr};
+
 #[derive(Debug)]
 enum Connector {
     Direct(TcpStream),

rsocket-transport-tcp/src/client/tls.rs

@@ -1,10 +1,12 @@
-use crate::connection::TlsConnection;
+use std::net::SocketAddr;
+
 use rsocket_rust::async_trait;
 use rsocket_rust::{error::RSocketError, transport::Transport, Result};
-use std::net::SocketAddr;
 use tokio::net::TcpStream;
 use tokio_native_tls::{TlsConnector, TlsStream};
 
+use crate::connection::TlsConnection;
+
 #[derive(Debug)]
 enum Connector {
     Direct(TlsStream<TcpStream>),

rsocket-transport-tcp/src/client/uds.rs

@@ -1,9 +1,10 @@
-use crate::connection::UnixConnection;
-use crate::misc::parse_uds_addr;
 use rsocket_rust::async_trait;
 use rsocket_rust::{error::RSocketError, transport::Transport, Result};
 use tokio::net::UnixStream;
 
+use crate::connection::UnixConnection;
+use crate::misc::parse_uds_addr;
+
 #[derive(Debug)]
 enum Connector {
     Direct(UnixStream),

rsocket-transport-tcp/src/connection/codec.rs

@@ -1,7 +1,8 @@
+use std::io::{Error, ErrorKind};
+
 use bytes::{Buf, BytesMut};
 use rsocket_rust::frame::Frame;
 use rsocket_rust::utils::{u24, Writeable};
-use std::io::{Error, ErrorKind};
 use tokio_util::codec::{Decoder, Encoder};
 
 pub struct LengthBasedFrameCodec;

rsocket-transport-tcp/src/connection/tcp.rs

@@ -1,9 +1,8 @@
 use futures::{SinkExt, StreamExt};
-use tokio::net::TcpStream;
-use tokio_util::codec::Framed;
-
 use rsocket_rust::error::RSocketError;
 use rsocket_rust::transport::{Connection, FrameSink, FrameStream};
+use tokio::net::TcpStream;
+use tokio_util::codec::Framed;
 
 use super::codec::LengthBasedFrameCodec;