chore: rm needless pass by ref mut

crates/pubsub/src/managers/active_sub.rs

@@ -76,7 +76,7 @@ impl ActiveSubscription {
 
     /// Notify the subscription channel of a new value, if any receiver exists.
     /// If no receiver exists, the notification is dropped.
-    pub(crate) fn notify(&mut self, notification: Box<RawValue>) {
+    pub(crate) fn notify(&self, notification: Box<RawValue>) {
         if self.tx.receiver_count() > 0 {
             let _ = self.tx.send(notification);
         }

crates/pubsub/src/managers/sub.rs

@@ -89,7 +89,7 @@ impl SubscriptionManager {
     /// exists, the notification is dropped.
     pub(crate) fn notify(&mut self, notification: EthNotification) {
         if let Some(local_id) = self.local_id_for(&notification.subscription) {
-            if let Some((_, mut sub)) = self.local_to_sub.remove_by_left(&local_id) {
+            if let Some((_, sub)) = self.local_to_sub.remove_by_left(&local_id) {
                 sub.notify(notification.result);
                 self.local_to_sub.insert(local_id, sub);
             }

crates/pubsub/src/service.rs

@@ -103,7 +103,7 @@ impl<T: PubSubConnect> PubSubService<T> {
     }
 
     /// Dispatch a request to the socket.
-    fn dispatch_request(&mut self, brv: Box<RawValue>) -> TransportResult<()> {
+    fn dispatch_request(&self, brv: Box<RawValue>) -> TransportResult<()> {
         self.handle.to_socket.send(brv).map(drop).map_err(|_| TransportErrorKind::backend_gone())
     }
 
@@ -123,7 +123,7 @@ impl<T: PubSubConnect> PubSubService<T> {
     /// the subscription does not exist, the waiter is sent nothing, and the
     /// `tx` is dropped. This notifies the waiter that the subscription does
     /// not exist.
-    fn service_get_sub(&mut self, local_id: B256, tx: oneshot::Sender<RawSubscription>) {
+    fn service_get_sub(&self, local_id: B256, tx: oneshot::Sender<RawSubscription>) {
         if let Some(rx) = self.subs.get_subscription(local_id) {
             let _ = tx.send(rx);
         }