diff --git a/relay_client/src/http.rs b/relay_client/src/http.rs
index c08d7c1..7ab3305 100644
--- a/relay_client/src/http.rs
+++ b/relay_client/src/http.rs
@@ -1,7 +1,8 @@
 use {
     crate::{
         error::{BoxError, ClientError, Error},
-        ConnectionOptions, MessageIdGenerator,
+        ConnectionOptions,
+        MessageIdGenerator,
     },
     http::{HeaderMap, StatusCode},
     relay_rpc::{
diff --git a/relay_client/src/websocket.rs b/relay_client/src/websocket.rs
index ac9b128..1eee8aa 100644
--- a/relay_client/src/websocket.rs
+++ b/relay_client/src/websocket.rs
@@ -7,9 +7,19 @@ use {
     relay_rpc::{
         domain::{MessageId, SubscriptionId, Topic},
         rpc::{
-            BatchFetchMessages, BatchReceiveMessages, BatchSubscribe, BatchSubscribeBlocking,
-            BatchUnsubscribe, FetchMessages, Publish, Receipt, Subscribe, SubscribeBlocking,
-            Subscription, SubscriptionError, Unsubscribe,
+            BatchFetchMessages,
+            BatchReceiveMessages,
+            BatchSubscribe,
+            BatchSubscribeBlocking,
+            BatchUnsubscribe,
+            FetchMessages,
+            Publish,
+            Receipt,
+            Subscribe,
+            SubscribeBlocking,
+            Subscription,
+            SubscriptionError,
+            Unsubscribe,
         },
     },
     std::{future::Future, sync::Arc, time::Duration},
@@ -19,7 +29,10 @@ use {
     },
 };
 pub use {
-    fetch::*, inbound::*, outbound::*, stream::*,
+    fetch::*,
+    inbound::*,
+    outbound::*,
+    stream::*,
     tokio_tungstenite::tungstenite::protocol::CloseFrame,
 };
 
diff --git a/relay_rpc/src/rpc/tests.rs b/relay_rpc/src/rpc/tests.rs
index affe696..543e5ee 100644
--- a/relay_rpc/src/rpc/tests.rs
+++ b/relay_rpc/src/rpc/tests.rs
@@ -75,14 +75,12 @@ fn response_result() {
 
 #[test]
 fn response_error() {
-    let payload: Payload = Payload::Response(Response::Error(ErrorResponse::new(
-        1.into(),
-        ErrorData {
+    let payload: Payload =
+        Payload::Response(Response::Error(ErrorResponse::new(1.into(), ErrorData {
             code: 32,
             data: None,
             message: "some message".into(),
-        },
-    )));
+        })));
 
     let serialized = serde_json::to_string(&payload).unwrap();