update code format

Author: luoluoyuyu

src/runtime/input/protocol/nats/nats_protocol.rs

@@ -36,9 +36,8 @@ impl InputProtocol for NatsProtocol {
     }
 
     fn init(&self) -> Result<(), Box<dyn std::error::Error + Send>> {
-        let nc = nats::connect(&self.config.url).map_err(|e| {
-            Box::new(std::io::Error::other(e)) as Box<dyn std::error::Error + Send>
-        })?;
+        let nc = nats::connect(&self.config.url)
+            .map_err(|e| Box::new(std::io::Error::other(e)) as Box<dyn std::error::Error + Send>)?;
 
         let sub = if let Some(q) = &self.config.queue_group {
             nc.queue_subscribe(&self.config.subject, q).map_err(|e| {

src/runtime/output/protocol/nats/nats_protocol.rs

@@ -35,9 +35,8 @@ impl OutputProtocol for NatsOutputProtocol {
     }
 
     fn init(&self) -> Result<(), Box<dyn std::error::Error + Send>> {
-        let nc = nats::connect(&self.config.url).map_err(|e| {
-            Box::new(std::io::Error::other(e)) as Box<dyn std::error::Error + Send>
-        })?;
+        let nc = nats::connect(&self.config.url)
+            .map_err(|e| Box::new(std::io::Error::other(e)) as Box<dyn std::error::Error + Send>)?;
         *self.connection.lock().unwrap() = Some(nc);
         Ok(())
     }
@@ -49,8 +48,9 @@ impl OutputProtocol for NatsOutputProtocol {
                 Box::new(std::io::Error::other("NATS connection not initialized"))
                     as Box<dyn std::error::Error + Send>
             })?;
-            nc.publish(&self.config.subject, &payload)
-                .map_err(|e| Box::new(std::io::Error::other(e)) as Box<dyn std::error::Error + Send>)?;
+            nc.publish(&self.config.subject, &payload).map_err(|e| {
+                Box::new(std::io::Error::other(e)) as Box<dyn std::error::Error + Send>
+            })?;
         }
         Ok(())
     }