style: improve code formatting and import organization

Author: sile

examples/epmd_cli.rs

@@ -57,10 +57,12 @@ fn main() -> orfail::Result<()> {
             Command::Names => {
                 // 'NAMES_REQ'
                 let names = client.get_names().await.or_fail()?;
-                let result = serde_json::json!(names
-                    .into_iter()
-                    .map(|(name, port)| serde_json::json!({"name": name, "port": port}))
-                    .collect::<Vec<_>>());
+                let result = serde_json::json!(
+                    names
+                        .into_iter()
+                        .map(|(name, port)| serde_json::json!({"name": name, "port": port}))
+                        .collect::<Vec<_>>()
+                );
                 println!("{}", serde_json::to_string_pretty(&result).or_fail()?);
             }
             Command::NodeEntry { node } => {

src/channel.rs

@@ -1,8 +1,8 @@
+use crate::DistributionFlags;
 #[cfg(doc)]
 use crate::handshake;
 use crate::io::Connection;
 use crate::message::Message;
-use crate::DistributionFlags;
 use futures::io::{AsyncRead, AsyncWrite};
 
 /// Makes a channel to send/received messages to/from a connected node.

src/epmd.rs

@@ -142,7 +142,10 @@ impl std::fmt::Display for EpmdError {
                 )
             }
             Self::MalformedNamesResponse { line } => {
-                write!(f,"found a malformed NAMES_RESP line: expected_format=\"name {{NAME}} at port {{PORT}}\", actual_line={line:?}")
+                write!(
+                    f,
+                    "found a malformed NAMES_RESP line: expected_format=\"name {{NAME}} at port {{PORT}}\", actual_line={line:?}"
+                )
             }
             Self::Io(error) => write!(f, "{error}"),
         }

src/handshake.rs

@@ -72,7 +72,7 @@ where
                 return Err(HandshakeError::PhaseError {
                     current: "ClientSideHandshake::execute_rest()",
                     depends_on: "ClientSideHandshake::execute_send_name()",
-                })
+                });
             }
             Some(HandshakeStatus::Nok) => return Err(HandshakeError::OngoingHandshake),
             Some(HandshakeStatus::NotAllowed) => return Err(HandshakeError::NotAllowed),
@@ -201,7 +201,7 @@ where
                 return Err(HandshakeError::UnexpectedTag {
                     message: "CHALLENGE",
                     tag,
-                })
+                });
             }
         };
         reader.finish().await?;
@@ -319,19 +319,15 @@ where
                 return Err(HandshakeError::UnexpectedTag {
                     message: "NAME",
                     tag,
-                })
+                });
             }
         };
         reader.finish().await?;
 
         let name = node.name.clone();
         let is_dynamic = node.flags.contains(DistributionFlags::NAME_ME);
         self.peer_node = Some(node);
-        if is_dynamic {
-            Ok(None)
-        } else {
-            Ok(Some(name))
-        }
+        if is_dynamic { Ok(None) } else { Ok(Some(name)) }
     }
 
     /// Executes the rest part of the handshake protocol.

src/message.rs

@@ -3,15 +3,15 @@
 //! Reference: [Protocol between Connected Nodes](https://www.erlang.org/doc/apps/erts/erl_dist_protocol.html#protocol-between-connected-nodes)
 //!
 //! Note that distribution headers are not supported in the current version.
+#[cfg(doc)]
+use crate::DistributionFlags;
 use crate::eetf_ext;
 use crate::io::{ReadTermExt, WriteTermExt};
 use crate::term::{Atom, FixInteger, List, Mfa, Pid, PidOrAtom, Reference, Term, Tuple};
-#[cfg(doc)]
-use crate::DistributionFlags;
 use eetf::{DecodeError, EncodeError};
 use std::io::{Read, Write};
 
-pub use crate::channel::{channel, Receiver, RecvError, SendError, Sender};
+pub use crate::channel::{Receiver, RecvError, SendError, Sender, channel};
 
 trait DistributionMessage: Sized {
     const OP: i32;