coil-runtime 0.1.0

HTTP runtime and request handling for the Coil framework.
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29

/// Submit blocking outbound HTTP work to Tokio's blocking pool.
///
/// The request thread only waits at the boundary; the actual network call and
/// body read run off the core worker lane when a multi-thread runtime is
/// present.
pub(super) fn offload_outbound_http_to_blocking_pool<T, F>(operation: F) -> Result<T, String>
where
    F: FnOnce() -> Result<T, String> + Send + 'static,
    T: Send + 'static,
{
    if matches!(
        tokio::runtime::Handle::try_current()
            .ok()
            .map(|handle| handle.runtime_flavor()),
        Some(tokio::runtime::RuntimeFlavor::MultiThread)
    ) {
        let handle = tokio::runtime::Handle::current();
        let join = handle.spawn_blocking(operation);
        tokio::task::block_in_place(|| {
            handle.block_on(async move {
                join.await.map_err(|error| {
                    format!("failed to execute outbound HTTP on the blocking pool: {error}")
                })?
            })
        })
    } else {
        operation()
    }
}