drivers: Use clone function over static method

Signed-off-by: Patrick José Pereira <[email protected]>
bluerobotics · Sep 16, 2024 · 0916009 · 0916009
1 parent 0d04421
commit 0916009
Show file tree

Hide file tree

Showing 2 changed files with 7 additions and 7 deletions.
diff --git a/src/drivers/fake.rs b/src/drivers/fake.rs
@@ -57,16 +57,16 @@ impl Driver for FakeSink {
             self.stats
                 .write()
                 .await
-                .update_input(Arc::clone(&message))
+                .update_input(message.clone())
                 .await;
 
             self.stats
                 .write()
                 .await
-                .update_input(Arc::clone(&message))
+                .update_input(message.clone())
                 .await;
 
-            for future in self.on_message_input.call_all(Arc::clone(&message)) {
+            for future in self.on_message_input.call_all(message.clone()) {
                 if let Err(error) = future.await {
                     debug!("Dropping message: on_message_input callback returned error: {error:?}");
                     continue;
@@ -219,10 +219,10 @@ impl Driver for FakeSource {
                         self.stats
                             .write()
                             .await
-                            .update_output(Arc::clone(&message))
+                            .update_output(message.clone())
                             .await;
 
-                        for future in self.on_message_output.call_all(Arc::clone(&message)) {
+                        for future in self.on_message_output.call_all(message.clone()) {
                             if let Err(error) = future.await {
                                 debug!(
                                     "Dropping message: on_message_input callback returned error: {error:?}"

diff --git a/src/drivers/mod.rs b/src/drivers/mod.rs
@@ -282,10 +282,10 @@ mod tests {
                 self.stats
                     .write()
                     .await
-                    .update_input(Arc::clone(&message))
+                    .update_input(message.clone())
                     .await;
 
-                for future in self.on_message_input.call_all(Arc::clone(&message)) {
+                for future in self.on_message_input.call_all(message.clone()) {
                     if let Err(error) = future.await {
                         debug!(
                             "Dropping message: on_message_input callback returned error: {error:?}"