Skip to content

Commit

Permalink
make clippy happy
Browse files Browse the repository at this point in the history
  • Loading branch information
bbalser committed Aug 26, 2023
1 parent ad31203 commit 3365724
Show file tree
Hide file tree
Showing 3 changed files with 3 additions and 2 deletions.
2 changes: 1 addition & 1 deletion iot_config/src/client/mod.rs
Original file line number Diff line number Diff line change
Expand Up @@ -143,7 +143,7 @@ impl gateway_info::GatewayInfoResolver for Client {
.filter_map(|resp| async move { resp.ok() })
.map(move |resp| (resp, pubkey.clone()))
.filter_map(|(resp, pubkey)| async move { resp.verify(&pubkey).map(|_| resp).ok() })
.flat_map(|resp| stream::iter(resp.gateways.into_iter()))
.flat_map(|resp| stream::iter(resp.gateways))
.map(gateway_info::GatewayInfo::from)
.boxed();

Expand Down
2 changes: 1 addition & 1 deletion mobile_config/src/client/gateway_client.rs
Original file line number Diff line number Diff line change
Expand Up @@ -98,7 +98,7 @@ impl gateway_info::GatewayInfoResolver for GatewayClient {
Err(_) => None,
}
})
.flat_map(|res| stream::iter(res.gateways.into_iter()))
.flat_map(|res| stream::iter(res.gateways))
.map(gateway_info::GatewayInfo::from)
.boxed();

Expand Down
1 change: 1 addition & 0 deletions task_manager/src/lib.rs
Original file line number Diff line number Diff line change
Expand Up @@ -134,6 +134,7 @@ fn start_futures(
.collect()
}

#[allow(clippy::manual_try_fold)]
async fn stop_all(futures: Vec<StopableLocalFuture>) -> anyhow::Result<()> {
futures::stream::iter(futures.into_iter().rev())
.fold(Ok(()), |last_result, local| async move {
Expand Down

0 comments on commit 3365724

Please sign in to comment.