hyli-net 0.15.0

Hyli network SDK
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

use std::{any::Any, future::Future};

use futures::FutureExt;
use tokio::task::{self, JoinHandle};

use std::{panic::AssertUnwindSafe, process};

fn log_panic_info(err: Box<dyn Any + Send>) {
    if let Some(s) = err.downcast_ref::<&'static str>() {
        tracing::error!("Task panicked with message: {}", s);
    } else if let Some(s) = err.downcast_ref::<String>() {
        tracing::error!("Task panicked with message: {}", s);
    } else {
        tracing::error!("Task panicked with non-string payload.");
    }
}

pub fn logged_task<F, T>(fut: F) -> JoinHandle<T>
where
    F: Future<Output = T> + Send + 'static,
    T: Send + 'static,
{
    task::spawn(async {
        match AssertUnwindSafe(fut).catch_unwind().await {
            Ok(result) => result,
            Err(e) => {
                log_panic_info(e);
                process::abort();
            }
        }
    })
}