File tree Expand file tree Collapse file tree 3 files changed +3
-3
lines changed
ic-agent/src/agent/http_transport/dynamic_routing Expand file tree Collapse file tree 3 files changed +3
-3
lines changed Original file line number Diff line number Diff line change @@ -251,7 +251,7 @@ impl<S> Drop for DynamicRouteProvider<S> {
251251 let tracker = self . tracker . clone ( ) ;
252252 // If no runtime is available do nothing.
253253 if let Ok ( handle) = Handle :: try_current ( ) {
254- let _ = handle. spawn ( async move {
254+ handle. spawn ( async move {
255255 tracker. wait ( ) . await ;
256256 warn ! ( "{DYNAMIC_ROUTE_PROVIDER}: stopped gracefully" ) ;
257257 } ) ;
Original file line number Diff line number Diff line change @@ -99,7 +99,7 @@ impl RoutingSnapshot for LatencyRoutingSnapshot {
9999 . cloned ( )
100100 . collect ( ) ;
101101 let has_added_nodes = !nodes_added. is_empty ( ) ;
102- self . existing_nodes . extend ( nodes_added. into_iter ( ) ) ;
102+ self . existing_nodes . extend ( nodes_added) ;
103103 // NOTE: newly added nodes will appear in the weighted_nodes later.
104104 // This happens after the first node health check round and a consequent update_node() invocation.
105105 for node in nodes_removed. into_iter ( ) {
Original file line number Diff line number Diff line change @@ -116,6 +116,6 @@ impl NodeHealthCheckerMock {
116116
117117 pub fn overwrite_healthy_nodes ( & self , healthy_nodes : Vec < Node > ) {
118118 self . healthy_nodes
119- . store ( Arc :: new ( HashSet :: from_iter ( healthy_nodes. into_iter ( ) ) ) ) ;
119+ . store ( Arc :: new ( HashSet :: from_iter ( healthy_nodes) ) ) ;
120120 }
121121}
You can’t perform that action at this time.
0 commit comments