java_asm_server 0.1.3

Java bytecode reader & writer in rust
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20

use std::future::Future;
use std::sync::Arc;
use tokio::runtime;
use tokio::runtime::Runtime;

pub fn new_tokio_thread<F, Fut>(async_logic: F)
where
    F: FnOnce(Arc<Runtime>) -> Fut + Send + 'static,
    Fut: Future,
{
    std::thread::spawn(move || {
        let runtime: Arc<Runtime> = runtime::Builder::new_multi_thread()
            .enable_all().build().unwrap().into();
        let copied_runtime = runtime.clone();
        runtime.block_on(async move {
            let runtime = copied_runtime;
            async_logic(runtime).await;
        });
    });
}