recoverable-spawn 3.9.19

A thread that supports automatic recovery from panics, allowing threads to restart after a panic. Useful for resilient and fault-tolerant concurrency in network and web programming.
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
38
39
40
41
42
43
44
45

use crate::*;

#[tokio::test]
async fn test_async_recoverable_spawn() {
    let msg: &str = "test";
    let res: AsyncSpawnResult = async_recoverable_spawn(move || async move {
        panic!("{}", msg);
    })
    .await;
    println!("test_async_recoverable_spawn handle res {res:?}");
}

#[tokio::test]
async fn test_async_recoverable_spawn_catch() {
    let msg: &str = "test";
    let res: AsyncSpawnResult = async_recoverable_spawn_catch(
        move || async move {
            panic!("{}", msg);
        },
        move |err| async move {
            println!("async handle error => {err}");
        },
    )
    .await;
    println!("test_async_recoverable_spawn_catch handle res {res:?}");
}

#[tokio::test]
async fn test_async_recoverable_spawn_catch_finally() {
    let msg: &str = "test";
    let res: AsyncSpawnResult = async_recoverable_spawn_catch_finally(
        move || async move {
            panic!("{}", msg);
        },
        move |err| async move {
            println!("async handle error => {err}");
            panic!("{}", err);
        },
        move || async move {
            println!("finally");
        },
    )
    .await;
    println!("test_async_recoverable_spawn_catch_finally handle res {res:?}");
}