cordis-core 0.3.0

Typed lifecycle, services, events, effects, and observation for the Cordis v3 runtime
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
30
31
32
33
34
35
36
37

//! Failure boundary for framework-owned spawned tasks.
//!
//! This is deliberately distinct from [`crate::contained`]. User-code
//! containment catches a panic and converts or discards it according to the
//! surrounding operation. A framework invariant panic is not recoverable: this
//! boundary only adds Runtime logger context, then resumes the same unwind so
//! the task still terminates as panicked. No lifecycle state is repaired here.

use crate::logger::Logger;
use futures::FutureExt;
use std::future::Future;
use std::panic::AssertUnwindSafe;

pub(crate) fn spawn<F>(
    handle: &tokio::runtime::Handle,
    logger: Logger,
    operation: &'static str,
    context: String,
    future: F,
) -> tokio::task::JoinHandle<F::Output>
where
    F: Future + Send + 'static,
    F::Output: Send + 'static,
{
    handle.spawn(async move {
        match AssertUnwindSafe(future).catch_unwind().await {
            Ok(output) => output,
            Err(payload) => {
                logger.error(format!(
                    "cordis: framework task {operation} panicked ({context}): {}",
                    crate::contained::payload_text(&payload)
                ));
                std::panic::resume_unwind(payload);
            }
        }
    })
}