change to mutable

EspressoSystems · Sep 9, 2024 · 5bd4b0e · 5bd4b0e
1 parent f10fa8b
commit 5bd4b0e
Show file tree

Hide file tree

Showing 3 changed files with 3 additions and 3 deletions.
diff --git a/cdn-broker/src/tasks/broker/handler.rs b/cdn-broker/src/tasks/broker/handler.rs
@@ -124,7 +124,7 @@ impl<Def: RunDef> Inner<Def> {
  connection: Connection,
  ) -> Result<()> {
  // Clone the hook
- let local_message_hook = self.broker_message_hook.clone();
+ let mut local_message_hook = self.broker_message_hook.clone();
 
  loop {
  // Receive a message from the broker

diff --git a/cdn-broker/src/tasks/user/handler.rs b/cdn-broker/src/tasks/user/handler.rs
@@ -98,7 +98,7 @@ impl<Def: RunDef> Inner<Def> {
  connection: Connection,
  ) -> Result<()> {
  // Clone the hook
- let local_message_hook = self.user_message_hook.clone();
+ let mut local_message_hook = self.user_message_hook.clone();
 
  loop {
  // Receive a message from the user

diff --git a/cdn-proto/src/def.rs b/cdn-proto/src/def.rs
@@ -80,7 +80,7 @@ pub trait MessageHookDef: Send + Sync + 'static + Clone {
  ///
  /// # Errors
  /// Is supposed to return an error if the other end should be disconnected.
- fn on_message_received(&self, _message: &mut Message) -> AnyhowResult<HookResult> {
+ fn on_message_received(&mut self, _message: &mut Message) -> AnyhowResult<HookResult> {
  Ok(HookResult::ProcessMessage)
  }
 }