Struct BlockingFuture

pub struct BlockingFuture<R: Sync + Send + 'static>(/* private fields */);

For the use in blocking context, spawn a future into given tokio runtime and wait for result.

example:

use tokio::time::*;
use sync_utils::blocking_async::BlockingFuture;
let rt = tokio::runtime::Builder::new_multi_thread()
    .enable_all()
    .worker_threads(1)
    .build()
    .unwrap();
let res = BlockingFuture::new().block_on(&rt, async move {
    println!("exec future");
    sleep(Duration::from_secs(1)).await;
    return "hello world".to_string();
});

Implementations

impl<R> BlockingFuture<R>

where R: Sync + Send + Clone + 'static,

pub fn new() -> Self

pub fn block_on<F>(&mut self, rt: &Runtime, f: F) -> R

where F: Future<Output = R> + Send + Sync + 'static,