Maker & Taker Actors does not need to be mut, applying cargo suggestions

nobu-maeda · Dec 21, 2023 · cb46c80 · cb46c80
1 parent dbd6f33
commit cb46c80
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 6 deletions.
diff --git a/src/maker/maker.rs b/src/maker/maker.rs
@@ -124,7 +124,7 @@ impl Maker {
         maker_dir_path: impl AsRef<Path>,
     ) -> Self {
         let (tx, rx) = mpsc::channel::<MakerRequest>(Self::MAKER_REQUEST_CHANNEL_SIZE);
-        let mut actor = MakerActor::new(rx, comms_accessor, order, maker_dir_path).await;
+        let actor = MakerActor::new(rx, comms_accessor, order, maker_dir_path).await;
         let task_handle = tokio::spawn(async move { actor.run().await });
         Self { tx, task_handle }
     }
@@ -134,8 +134,7 @@ impl Maker {
         maker_data_path: impl AsRef<Path>,
     ) -> Result<(Uuid, Self), N3xbError> {
         let (tx, rx) = mpsc::channel::<MakerRequest>(Self::MAKER_REQUEST_CHANNEL_SIZE);
-        let (trade_uuid, mut actor) =
-            MakerActor::restore(rx, comms_accessor, maker_data_path).await?;
+        let (trade_uuid, actor) = MakerActor::restore(rx, comms_accessor, maker_data_path).await?;
         let task_handle = tokio::spawn(async move { actor.run().await });
         let maker = Self { tx, task_handle };
         Ok((trade_uuid, maker))

diff --git a/src/taker/taker.rs b/src/taker/taker.rs
@@ -97,7 +97,7 @@ impl Taker {
         taker_dir_path: impl AsRef<Path>,
     ) -> Self {
         let (tx, rx) = mpsc::channel::<TakerRequest>(Self::TAKER_REQUEST_CHANNEL_SIZE);
-        let mut actor =
+        let actor =
             TakerActor::new(rx, comms_accessor, order_envelope, offer, taker_dir_path).await;
         let task_handle = tokio::spawn(async move { actor.run().await });
         Self { tx, task_handle }
@@ -108,8 +108,7 @@ impl Taker {
         taker_data_path: impl AsRef<Path>,
     ) -> Result<(Uuid, Self), N3xbError> {
         let (tx, rx) = mpsc::channel::<TakerRequest>(Self::TAKER_REQUEST_CHANNEL_SIZE);
-        let (trade_uuid, mut actor) =
-            TakerActor::restore(rx, comms_accessor, taker_data_path).await?;
+        let (trade_uuid, actor) = TakerActor::restore(rx, comms_accessor, taker_data_path).await?;
         let task_handle = tokio::spawn(async move { actor.run().await });
         let taker = Self { tx, task_handle };
         Ok((trade_uuid, taker))