Reformat codes.

Author: jjeffcaii

examples/echo-uds-client.rs

@@ -5,7 +5,6 @@ use std::error::Error;
 
 #[tokio::main]
 async fn main() -> Result<(), Box<dyn Error + Send + Sync>> {
-    
     let responder: ClientResponder = Box::new(|| Box::new(EchoRSocket));
 
     let client = RSocketFactory::connect()
@@ -29,4 +28,4 @@ async fn main() -> Result<(), Box<dyn Error + Send + Sync>> {
     client.close();
 
     Ok(())
-}
+}

examples/echo-uds.rs

@@ -5,7 +5,6 @@ use std::error::Error;
 
 #[tokio::main]
 async fn main() -> Result<(), Box<dyn Error + Send + Sync>> {
-
     let transport: UnixServerTransport = UnixServerTransport::from("/tmp/rsocket-uds.sock");
 
     let responder: ServerResponder = Box::new(|setup, _socket| {
@@ -26,4 +25,4 @@ async fn main() -> Result<(), Box<dyn Error + Send + Sync>> {
         .await?;
 
     Ok(())
-}
+}

rsocket-transport-unix/src/client.rs

@@ -1,14 +1,14 @@
 use super::codec::LengthBasedFrameCodec;
 use futures::{SinkExt, StreamExt};
-use std::os::unix::net::UnixStream as StdUnixStream;
-use std::str::FromStr;
-use std::io;
-use tokio::net::UnixStream;
-use tokio_util::codec::Framed;
 use rsocket_rust::error::RSocketError;
 use rsocket_rust::frame::Frame;
 use rsocket_rust::runtime::{DefaultSpawner, Spawner};
 use rsocket_rust::transport::{ClientTransport, Rx, Tx, TxOnce};
+use std::io;
+use std::os::unix::net::UnixStream as StdUnixStream;
+use std::str::FromStr;
+use tokio::net::UnixStream;
+use tokio_util::codec::Framed;
 
 enum Connector {
     Direct(UnixStream),
@@ -20,10 +20,9 @@ pub struct UnixClientTransport {
 }
 
 impl UnixClientTransport {
-
     #[inline]
     fn new(connector: Connector) -> UnixClientTransport {
-        UnixClientTransport{ connector }
+        UnixClientTransport { connector }
     }
 
     #[inline]

rsocket-transport-unix/src/lib.rs

@@ -4,8 +4,8 @@
 extern crate log;
 
 mod client;
-mod server;
 mod codec;
+mod server;
 
 pub use client::UnixClientTransport;
-pub use server::UnixServerTransport;
+pub use server::UnixServerTransport;

rsocket-transport-unix/src/server.rs

@@ -27,7 +27,7 @@ impl ServerTransport for UnixServerTransport {
         Self::Item: ClientTransport + Sized,
     {
         Box::pin(async move {
-            match UnixListener::bind(&self.addr.as_str()){
+            match UnixListener::bind(&self.addr.as_str()) {
                 Ok(mut listener) => {
                     debug!("listening on: {}", &self.addr);
                     if let Some(mut bingo) = starter {
@@ -37,7 +37,7 @@ impl ServerTransport for UnixServerTransport {
                         let tp = UnixClientTransport::from(socket);
                         acceptor(tp);
                     }
-                    
+
                     Ok(())
                 }
                 Err(e) => Err(e.into_inner().unwrap()),