diff --git a/coerce/src/remote/cluster/singleton/manager/mod.rs b/coerce/src/remote/cluster/singleton/manager/mod.rs index 98e7d80..729c603 100644 --- a/coerce/src/remote/cluster/singleton/manager/mod.rs +++ b/coerce/src/remote/cluster/singleton/manager/mod.rs @@ -155,12 +155,19 @@ impl Handler> for Manager { 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 Handler> for Manager { 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 index e14fc3f..f301d83 100644 --- 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() };