1
2
3
4
5
6
7
8
9
10
11
12

use once_cell::sync::Lazy;

static RT: Lazy<tokio::runtime::Runtime> = Lazy::new(|| {
    tokio::runtime::Builder::new_multi_thread()
        .enable_all()
        .build()
        .unwrap()
});

pub fn run_with_thread_local_runtime<O>(fut: impl std::future::Future<Output = O>) -> O {
    RT.block_on(fut)
}