From 6dd05b13eed8f9f124d12812a1561fa85a575bc4 Mon Sep 17 00:00:00 2001
From: tv <tv@krebsco.de>
Date: Mon, 19 Oct 2026 23:56:52 +0200
Subject: cargo fmt

---
 src/mycelium.rs | 10 ++--------
 1 file changed, 2 insertions(+), 8 deletions(-)

(limited to 'src/mycelium.rs')

diff --git a/src/mycelium.rs b/src/mycelium.rs
index 3471f71..8d0821b 100644
--- a/src/mycelium.rs
+++ b/src/mycelium.rs
@@ -33,7 +33,6 @@ const TOPIC_PONG: &str = "continuum.v1.pong";
 
 const EMPTY_QUEUE_DELAY: Duration = Duration::from_millis(25);
 
-
 #[derive(Debug, Deserialize)]
 #[serde(rename_all = "camelCase")]
 struct InboundMessage {
@@ -555,10 +554,7 @@ impl Transport for MyceliumTransport {
     }
 
     async fn send_encoded(&self, message: &EncodedMessage) -> Result<()> {
-        tracing::debug!(
-            payload_bytes = message.body.len(),
-            "Sending message"
-        );
+        tracing::debug!(payload_bytes = message.body.len(), "Sending message");
         let response = self
             .client
             .post(self.messages_endpoint.clone())
@@ -700,9 +696,7 @@ fn decode_payload(topic: &str, payload: &str) -> Result<ParsedMessage, Transport
         }
         TOPIC_PING => Ok(ParsedMessage::Ping(bytes_to_keepalive(&bytes)?)),
         TOPIC_PONG => Ok(ParsedMessage::Pong(bytes_to_keepalive(&bytes)?)),
-        t => {
-            Err(TransportError::UnknownTopic(t.to_string()))
-        }
+        t => Err(TransportError::UnknownTopic(t.to_string())),
     }
 }
 
-- 
cgit v1.3.1