diff --git a/ds/src/error.rs b/ds/src/error.rs
index cc12769..27d795e 100644
--- a/ds/src/error.rs
+++ b/ds/src/error.rs
@@ -14,4 +14,3 @@ pub enum DeliveryServiceError {
     #[error("An unknown error occurred: {0}")]
     Other(anyhow::Error),
 }
-
diff --git a/ds/src/lib.rs b/ds/src/lib.rs
index da7a465..e05824c 100644
--- a/ds/src/lib.rs
+++ b/ds/src/lib.rs
@@ -1,6 +1,6 @@
 pub mod error;
-pub mod transport;
 pub mod topic_filter;
+pub mod transport;
 pub mod waku;
 
 pub use error::DeliveryServiceError;
diff --git a/ds/src/topic_filter.rs b/ds/src/topic_filter.rs
index cbb39aa..50a0c70 100644
--- a/ds/src/topic_filter.rs
+++ b/ds/src/topic_filter.rs
@@ -43,10 +43,7 @@ impl TopicFilter {
 
     /// Remove all subtopics for a group.
     pub async fn remove_many(&self, group_name: &str) {
-        self.list
-            .write()
-            .await
-            .retain(|x| x.group_id != group_name);
+        self.list.write().await.retain(|x| x.group_id != group_name);
     }
 
     /// Membership test (first-stage filter).
diff --git a/src/user/waku.rs b/src/user/waku.rs
index 06c7136..a5d64c4 100644
--- a/src/user/waku.rs
+++ b/src/user/waku.rs
@@ -4,8 +4,7 @@ use tracing::{debug, error, info};
 
 use ds::{
     transport::{InboundPacket, OutboundPacket},
-    APP_MSG_SUBTOPIC,
-    WELCOME_SUBTOPIC,
+    APP_MSG_SUBTOPIC, WELCOME_SUBTOPIC,
 };
 
 use crate::{
diff --git a/tests/user_test.rs b/tests/user_test.rs
index 62f4df7..bdffecc 100644
--- a/tests/user_test.rs
+++ b/tests/user_test.rs
@@ -360,7 +360,8 @@ async fn process_and_handle_trigger_event_message(
         msgs_to_send.extend(wmts);
     }
 
-    let waku_msgs_to_send: Vec<InboundPacket> = msgs_to_send.into_iter().map(outbound_to_inbound).collect();
+    let waku_msgs_to_send: Vec<InboundPacket> =
+        msgs_to_send.into_iter().map(outbound_to_inbound).collect();
 
     let user_state = user
         .get_group_state(GROUP_NAME)