Formatting

Author: dnwiebe

node/src/proxy_client/stream_handler_pool.rs

@@ -114,7 +114,11 @@ impl StreamHandlerPoolReal {
         let inner_arc_1 = inner_arc.clone();
         let logger = Self::make_logger_copy(&inner_arc);
         let data_len = payload.sequenced_packet.data.len();
-        let hostname = payload.target_hostname.as_ref().unwrap_or(&"<unknown>".to_string()).to_string();
+        let hostname = payload
+            .target_hostname
+            .as_ref()
+            .unwrap_or(&"<unknown>".to_string())
+            .to_string();
         let target_port = payload.target_port;
         match Self::find_stream_with_key(&stream_key, &inner_arc) {
             Some(sender_wrapper) => {
@@ -245,7 +249,7 @@ impl StreamHandlerPoolReal {
             logger,
             "Queueing write of {} bytes{} to {} on stream {}",
             payload_size,
-            if last_data {" (last data)"} else {""},
+            if last_data { " (last data)" } else { "" },
             sender_wrapper.peer_addr(),
             stream_key,
         );
@@ -448,7 +452,8 @@ impl StreamHandlerPoolReal {
             logger,
             "Found IP addresses for {}: {:?}", target_hostname, &filtered_ip_addrs
         );
-        let result = establisher.establish_stream(payload, filtered_ip_addrs, target_hostname.clone());
+        let result =
+            establisher.establish_stream(payload, filtered_ip_addrs, target_hostname.clone());
         match result {
             Ok(sender_wrapper) => {
                 debug!(
@@ -458,7 +463,7 @@ impl StreamHandlerPoolReal {
                     sender_wrapper.peer_addr()
                 );
                 Ok(sender_wrapper)
-            },
+            }
             Err(e) => {
                 debug!(
                     logger,

node/src/proxy_client/stream_writer.rs

@@ -93,7 +93,7 @@ impl StreamWriter {
                         "Writing {} bytes from packet {}{} over existing stream",
                         packet.data.len(),
                         packet.sequence_number,
-                        if packet.last_data {" (last data)"} else {""}
+                        if packet.last_data { " (last data)" } else { "" }
                     );
                     match self.stream.poll_write(&packet.data) {
                         Err(e) => {
@@ -103,7 +103,7 @@ impl StreamWriter {
                                     "Error writing {} bytes from packet {}{}: {}",
                                     packet.data.len(),
                                     packet.sequence_number,
-                                    if packet.last_data {" (last data)"} else {""},
+                                    if packet.last_data { " (last data)" } else { "" },
                                     e
                                 );
                                 return Err(());

node/src/sub_lib/route.rs

@@ -329,12 +329,7 @@ pub struct RouteSegment {
 impl Debug for RouteSegment {
     fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
         let keys_base64: Vec<String> = self.keys.iter().map(|k| k.to_string()).collect();
-        write!(
-            f,
-            "{} : {:?}",
-            keys_base64.join(" -> "),
-            self.recipient
-        )
+        write!(f, "{} : {:?}", keys_base64.join(" -> "), self.recipient)
     }
 }