async: Relayout use crate.

The first block uses the standard library.
The second block uses the third party crates,
and the third block uses this crate.

Signed-off-by: wllenyj <[email protected]>

Author: wllenyj

src/asynchronous/client.rs

@@ -3,24 +3,24 @@
 // SPDX-License-Identifier: Apache-2.0
 //
 
-use nix::unistd::close;
 use std::collections::HashMap;
 use std::convert::TryInto;
 use std::os::unix::io::RawFd;
 use std::sync::{Arc, Mutex};
 
-use crate::common::client_connect;
-use crate::error::{Error, Result};
-use crate::proto::{Code, Codec, GenMessage, Message, Request, Response, MESSAGE_TYPE_RESPONSE};
-
-use crate::r#async::utils;
+use nix::unistd::close;
 use tokio::{
     self,
     io::split,
     sync::mpsc::{channel, Receiver, Sender},
     sync::Notify,
 };
 
+use crate::common::client_connect;
+use crate::error::{Error, Result};
+use crate::proto::{Code, Codec, GenMessage, Message, Request, Response, MESSAGE_TYPE_RESPONSE};
+use crate::r#async::utils;
+
 type RequestSender = Sender<(GenMessage, Sender<Result<Vec<u8>>>)>;
 type RequestReceiver = Receiver<(GenMessage, Sender<Result<Vec<u8>>>)>;
 

src/asynchronous/server.rs

@@ -3,26 +3,18 @@
 // SPDX-License-Identifier: Apache-2.0
 //
 
-use crate::r#async::utils;
-use nix::unistd;
 use std::collections::HashMap;
+use std::marker::Unpin;
 use std::os::unix::io::RawFd;
+use std::os::unix::io::{AsRawFd, FromRawFd};
+use std::os::unix::net::UnixListener as SysUnixListener;
 use std::result::Result as StdResult;
 use std::sync::Arc;
 use std::time::Duration;
 
-use crate::asynchronous::stream::{receive, respond, respond_with_status};
-use crate::asynchronous::unix_incoming::UnixIncoming;
-use crate::common::{self, Domain};
-use crate::context;
-use crate::error::{get_status, Error, Result};
-use crate::proto::{Code, MessageHeader, Status, MESSAGE_TYPE_REQUEST};
-use crate::r#async::{MethodHandler, TtrpcContext};
 use futures::stream::Stream;
 use futures::StreamExt as _;
-use std::marker::Unpin;
-use std::os::unix::io::{AsRawFd, FromRawFd};
-use std::os::unix::net::UnixListener as SysUnixListener;
+use nix::unistd;
 use tokio::{
     self,
     io::{split, AsyncRead, AsyncWrite, AsyncWriteExt},
@@ -32,10 +24,18 @@ use tokio::{
     sync::watch,
     time::timeout,
 };
-
 #[cfg(target_os = "linux")]
 use tokio_vsock::VsockListener;
 
+use crate::asynchronous::stream::{receive, respond, respond_with_status};
+use crate::asynchronous::unix_incoming::UnixIncoming;
+use crate::common::{self, Domain};
+use crate::context;
+use crate::error::{get_status, Error, Result};
+use crate::proto::{Code, MessageHeader, Status, MESSAGE_TYPE_REQUEST};
+use crate::r#async::utils;
+use crate::r#async::{MethodHandler, TtrpcContext};
+
 /// A ttrpc Server (async).
 pub struct Server {
     listeners: Vec<RawFd>,

src/asynchronous/stream.rs

@@ -3,14 +3,15 @@
 // SPDX-License-Identifier: Apache-2.0
 //
 
+use protobuf::Message;
+use tokio::io::AsyncReadExt;
+
 use crate::error::{get_rpc_status, sock_error_msg, Error, Result};
 use crate::proto::{
     Code, Response, Status, MESSAGE_HEADER_LENGTH, MESSAGE_LENGTH_MAX, MESSAGE_TYPE_RESPONSE,
 };
 use crate::r#async::utils;
 use crate::MessageHeader;
-use protobuf::Message;
-use tokio::io::AsyncReadExt;
 
 async fn receive_count<T>(reader: &mut T, count: usize) -> Result<Vec<u8>>
 where

src/asynchronous/utils.rs

@@ -3,17 +3,17 @@
 // SPDX-License-Identifier: Apache-2.0
 //
 
-use crate::error::{get_status, Result};
-use crate::proto::{
-    Code, MessageHeader, Request, Status, MESSAGE_TYPE_RESPONSE,
-};
-use async_trait::async_trait;
-use protobuf::{CodedInputStream, Message};
 use std::collections::HashMap;
 use std::os::unix::io::{FromRawFd, RawFd};
 use std::result::Result as StdResult;
+
+use async_trait::async_trait;
+use protobuf::{CodedInputStream, Message};
 use tokio::net::UnixStream;
 
+use crate::error::{get_status, Result};
+use crate::proto::{Code, MessageHeader, Request, Status, MESSAGE_TYPE_RESPONSE};
+
 /// Handle request in async mode.
 #[macro_export]
 macro_rules! async_request_handler {