Skip to content

Commit

Permalink
fix: clippy
Browse files Browse the repository at this point in the history
  • Loading branch information
nikolay-komarevskiy committed Jul 16, 2024
1 parent ea4c8e5 commit f79efc3
Show file tree
Hide file tree
Showing 3 changed files with 3 additions and 3 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -251,7 +251,7 @@ impl<S> Drop for DynamicRouteProvider<S> {
let tracker = self.tracker.clone();
// If no runtime is available do nothing.
if let Ok(handle) = Handle::try_current() {
let _ = handle.spawn(async move {
handle.spawn(async move {
tracker.wait().await;
warn!("{DYNAMIC_ROUTE_PROVIDER}: stopped gracefully");
});
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -99,7 +99,7 @@ impl RoutingSnapshot for LatencyRoutingSnapshot {
.cloned()
.collect();
let has_added_nodes = !nodes_added.is_empty();
self.existing_nodes.extend(nodes_added.into_iter());
self.existing_nodes.extend(nodes_added);
// NOTE: newly added nodes will appear in the weighted_nodes later.
// This happens after the first node health check round and a consequent update_node() invocation.
for node in nodes_removed.into_iter() {
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -116,6 +116,6 @@ impl NodeHealthCheckerMock {

pub fn overwrite_healthy_nodes(&self, healthy_nodes: Vec<Node>) {
self.healthy_nodes
.store(Arc::new(HashSet::from_iter(healthy_nodes.into_iter())));
.store(Arc::new(HashSet::from_iter(healthy_nodes)));
}
}

0 comments on commit f79efc3

Please sign in to comment.