diff --git a/crates/crates_io_tarball/src/lib.rs b/crates/crates_io_tarball/src/lib.rs index e9df7a9e4bf..b32e5f2eda4 100644 --- a/crates/crates_io_tarball/src/lib.rs +++ b/crates/crates_io_tarball/src/lib.rs @@ -326,7 +326,7 @@ mod tests { #[tokio::test] async fn process_tarball_test_incorrect_manifest_casing() { - let process = |file| async move { + let process = async |file| { let tarball = TarballBuilder::new() .add_file(&format!("foo-0.0.1/{file}"), MANIFEST) .build(); @@ -343,7 +343,7 @@ mod tests { #[tokio::test] async fn process_tarball_test_multiple_manifests() { - let process = |files: Vec<_>| async move { + let process = async |files: Vec<_>| { let tarball = files .iter() .fold(TarballBuilder::new(), |builder, file| { diff --git a/crates/crates_io_worker/src/worker.rs b/crates/crates_io_worker/src/worker.rs index 100d9a9ea17..149bc52ac5e 100644 --- a/crates/crates_io_worker/src/worker.rs +++ b/crates/crates_io_worker/src/worker.rs @@ -75,7 +75,7 @@ impl Worker { let job_id = job.id; debug!("Running job…"); - let future = with_sentry_transaction(&job.job_type, || async { + let future = with_sentry_transaction(&job.job_type, async || { let run_task_fn = job_registry .get(&job.job_type) .ok_or_else(|| anyhow!("Unknown job type {}", job.job_type))?; diff --git a/src/controllers/krate/delete.rs b/src/controllers/krate/delete.rs index 5d89db3b062..0c2ee7b3934 100644 --- a/src/controllers/krate/delete.rs +++ b/src/controllers/krate/delete.rs @@ -236,7 +236,7 @@ mod tests { #[tokio::test] async fn test_query_params() -> anyhow::Result<()> { - let check = |uri| async move { + let check = async |uri| { let request = Request::builder().uri(uri).body(())?; let (mut parts, _) = request.into_parts(); Ok::<_, anyhow::Error>(parts.extract::().await?) diff --git a/src/controllers/krate/publish.rs b/src/controllers/krate/publish.rs index 0d4d7f5568b..3350e8d4292 100644 --- a/src/controllers/krate/publish.rs +++ b/src/controllers/krate/publish.rs @@ -527,11 +527,11 @@ pub async fn publish(app: AppState, req: Parts, body: Body) -> AppResult(None) }), - updates_feed_job.enqueue(conn).or_else(|error| async move { + updates_feed_job.enqueue(conn).or_else(async |error| { error!("Failed to enqueue `rss::SyncUpdatesFeed` job: {error}"); Ok::<_, EnqueueError>(None) }), @@ -543,11 +543,11 @@ pub async fn publish(app: AppState, req: Parts, body: Body) -> AppResult(None) }), - typosquat_job.enqueue(conn).or_else(|error| async move { + typosquat_job.enqueue(conn).or_else(async |error| { error!("Failed to enqueue `CheckTyposquat` job: {error}"); Ok::<_, EnqueueError>(None) }), diff --git a/src/middleware/cargo_compat.rs b/src/middleware/cargo_compat.rs index 0e74dab6021..21b1826bb43 100644 --- a/src/middleware/cargo_compat.rs +++ b/src/middleware/cargo_compat.rs @@ -142,10 +142,9 @@ mod tests { use tower::ServiceExt; fn build_app() -> Router { - let okay = get(|| async { "Everything is okay" }); - let teapot = get(|| async { (StatusCode::IM_A_TEAPOT, "I'm a teapot") }); - let internal = - get(|| async { (StatusCode::INTERNAL_SERVER_ERROR, "Internal Server Error") }); + let okay = get(async || "Everything is okay"); + let teapot = get(async || (StatusCode::IM_A_TEAPOT, "I'm a teapot")); + let internal = get(async || (StatusCode::INTERNAL_SERVER_ERROR, "Internal Server Error")); Router::new() .route("/api/ok", okay.clone()) @@ -153,10 +152,10 @@ mod tests { .route("/teapot", teapot) .route("/api/500", internal.clone()) .route("/500", internal) - .route("/api/v1/crates/new", put(|| async { StatusCode::CREATED })) + .route("/api/v1/crates/new", put(async || StatusCode::CREATED)) .route( "/api/v1/crates/{crate_id}/owners", - get(|| async { StatusCode::INTERNAL_SERVER_ERROR }), + get(async || StatusCode::INTERNAL_SERVER_ERROR), ) .layer(from_fn_with_state(StatusCodeConfig::AdjustAll, middleware)) } diff --git a/src/router.rs b/src/router.rs index bd58d51fc00..88ce4c62beb 100644 --- a/src/router.rs +++ b/src/router.rs @@ -110,12 +110,10 @@ pub fn build_axum_router(state: AppState) -> Router<()> { } router - .route("/api/openapi.json", get(|| async { Json(openapi) })) - .fallback(|method: Method| async move { - match method { - Method::HEAD => StatusCode::NOT_FOUND.into_response(), - _ => not_found().into_response(), - } + .route("/api/openapi.json", get(async || Json(openapi))) + .fallback(async |method: Method| match method { + Method::HEAD => StatusCode::NOT_FOUND.into_response(), + _ => not_found().into_response(), }) .with_state(state) } diff --git a/src/worker/jobs/archive_version_downloads.rs b/src/worker/jobs/archive_version_downloads.rs index fc338c5d393..f827079ef2e 100644 --- a/src/worker/jobs/archive_version_downloads.rs +++ b/src/worker/jobs/archive_version_downloads.rs @@ -191,7 +191,7 @@ async fn upload( let directory = directory.as_ref(); let uploaded_dates = futures_util::stream::iter(dates) - .map(|date| async move { + .map(async |date| { let path = directory.join(format!("{date}.csv")); let result = upload_file(store, &path).await; result.map(|_| date).inspect_err(|error| {