http_handle/
async_runtime.rs

1// SPDX-License-Identifier: AGPL-3.0-only
2// Copyright (c) 2026 Sebastien Rousseau
3
4//! Async runtime helpers for panic-safe blocking execution.
5
6use crate::error::ServerError;
7
8/// Runs a blocking function on Tokio's blocking pool and maps panics/joins to `TaskFailed`.
9#[cfg(feature = "async")]
10#[cfg_attr(docsrs, doc(cfg(feature = "async")))]
11///
12/// # Examples
13///
14/// ```rust,no_run
15/// use http_handle::async_runtime::run_blocking;
16/// use http_handle::ServerError;
17/// # #[tokio::main(flavor = "current_thread")]
18/// # async fn main() -> Result<(), ServerError> {
19/// let value = run_blocking(|| Ok::<_, ServerError>(42)).await?;
20/// assert_eq!(value, 42);
21/// # Ok(())
22/// # }
23/// ```
24///
25/// # Errors
26///
27/// Returns the operation error or `TaskFailed` when the blocking task panics or join fails.
28///
29/// # Panics
30///
31/// This function does not panic.
32pub async fn run_blocking<F, T>(operation: F) -> Result<T, ServerError>
33where
34    F: FnOnce() -> Result<T, ServerError> + Send + 'static,
35    T: Send + 'static,
36{
37    match tokio::task::spawn_blocking(operation).await {
38        Ok(result) => result,
39        Err(err) => Err(ServerError::TaskFailed(format!(
40            "blocking task failed: {err}"
41        ))),
42    }
43}
44
45/// Non-async fallback for builds without async feature.
46#[cfg(not(feature = "async"))]
47///
48/// # Examples
49///
50/// ```rust
51/// use http_handle::async_runtime::run_blocking;
52/// use http_handle::ServerError;
53/// let value = run_blocking(|| Ok::<_, ServerError>(7)).expect("ok");
54/// assert_eq!(value, 7);
55/// ```
56///
57/// # Errors
58///
59/// Returns the operation error.
60///
61/// # Panics
62///
63/// This function does not panic.
64pub fn run_blocking<F, T>(operation: F) -> Result<T, ServerError>
65where
66    F: FnOnce() -> Result<T, ServerError>,
67{
68    operation()
69}
70
71#[cfg(all(test, feature = "async"))]
72mod tests {
73    use super::*;
74
75    #[tokio::test]
76    async fn run_blocking_maps_panic_to_task_failed() {
77        let result = run_blocking(|| -> Result<(), ServerError> {
78            panic!("boom")
79        })
80        .await;
81        assert!(matches!(result, Err(ServerError::TaskFailed(_))));
82    }
83
84    #[tokio::test]
85    async fn run_blocking_returns_inner_error() {
86        let result = run_blocking(|| -> Result<(), ServerError> {
87            Err(ServerError::Custom("inner".to_string()))
88        })
89        .await;
90        assert!(matches!(result, Err(ServerError::Custom(_))));
91    }
92
93    #[tokio::test]
94    async fn run_blocking_returns_success_value() {
95        let result =
96            run_blocking(|| -> Result<usize, ServerError> { Ok(7) })
97                .await
98                .expect("ok");
99        assert_eq!(result, 7);
100    }
101}
http_handle/async_runtime.rs

http_handle/
async_runtime.rs
