fix build

LeonHartley · Jan 4, 2024 · fbf6bc2 · fbf6bc2
1 parent 2ae5502
commit fbf6bc2
Show file tree

Hide file tree

Showing 2 changed files with 21 additions and 5 deletions.
diff --git a/coerce/src/remote/cluster/singleton/manager/mod.rs b/coerce/src/remote/cluster/singleton/manager/mod.rs
@@ -155,12 +155,19 @@ impl<F: SingletonFactory> Handler<Receive<SystemTopic>> for Manager<F> {
                     nodes,
                 }) => {
                     for node in nodes {
-                        if !self.selector.includes(node.as_ref()) && node.id != &self.node_id {
+                        if !self.selector.includes(node.as_ref()) && node.id != self.node_id {
                             continue;
                         }
 
-                        self.managers
-                            .insert(node.id, RemoteActorRef::new(self.manager_actor_id.clone(), node.id, sys.clone()).into());
+                        self.managers.insert(
+                            node.id,
+                            RemoteActorRef::new(
+                                self.manager_actor_id.clone(),
+                                node.id,
+                                sys.clone(),
+                            )
+                            .into(),
+                        );
                     }
 
                     if leader == &self.node_id {
@@ -178,7 +185,12 @@ impl<F: SingletonFactory> Handler<Receive<SystemTopic>> for Manager<F> {
                     if self.selector.includes(node.as_ref()) {
                         let mut entry = self.managers.entry(node.id);
                         if let Entry::Vacant(mut entry) = entry {
-                            let remote_ref = RemoteActorRef::new(self.manager_actor_id.clone(), node.id, sys.clone()).into();
+                            let remote_ref = RemoteActorRef::new(
+                                self.manager_actor_id.clone(),
+                                node.id,
+                                sys.clone(),
+                            )
+                            .into();
                             entry.insert(remote_ref);
                         }
                     }

diff --git a/coerce/src/remote/stream/system.rs b/coerce/src/remote/stream/system.rs
@@ -126,7 +126,11 @@ impl StreamData for SystemEvent {
                 ClusterEvent::MemberUp(member_up) => {
                     let event = MemberUpEvent {
                         leader_id: member_up.leader_id,
-                        nodes: member_up.nodes.iter().map(|n| n.as_ref().clone().into()).collect(),
+                        nodes: member_up
+                            .nodes
+                            .iter()
+                            .map(|n| n.as_ref().clone().into())
+                            .collect(),
                         ..Default::default()
                     };