fix: cargo fmt

Author: bmuddha

magicblock-replicator/src/connection.rs

@@ -5,8 +5,10 @@ use futures::{SinkExt, StreamExt};
 use tokio::io::{AsyncRead, AsyncWrite};
 use tokio_util::codec::{FramedRead, FramedWrite, LengthDelimitedCodec};
 
-use crate::error::{Error, Result};
-use crate::proto::Message;
+use crate::{
+    error::{Error, Result},
+    proto::Message,
+};
 
 /// Encodes `Message` with 4-byte LE length prefix.
 pub struct MessageEncoder;
@@ -43,7 +45,8 @@ impl<IO: AsyncRead + Unpin> Receiver<IO> {
     }
 
     pub async fn recv(&mut self) -> Result<Message> {
-        let frame = self.inner.next().await.ok_or(Error::ConnectionClosed)??;
+        let frame =
+            self.inner.next().await.ok_or(Error::ConnectionClosed)??;
         bincode::deserialize(&frame).map_err(Into::into)
     }
 }
@@ -55,7 +58,9 @@ pub struct Sender<IO> {
 
 impl<IO: AsyncWrite + Unpin> Sender<IO> {
     pub fn new(io: IO) -> Self {
-        Self { inner: FramedWrite::new(io, MessageEncoder) }
+        Self {
+            inner: FramedWrite::new(io, MessageEncoder),
+        }
     }
 
     pub async fn send(&mut self, msg: Message) -> Result<()> {