simulon 0.0.8

A simulation engine for distributed algorithms
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19

use futures::{future::LocalBoxFuture, Future};
use futures_task::{LocalFutureObj, LocalSpawn};

use crate::state::with_node;

/// Spawns the given future in its own task to be continued.
pub fn spawn<F>(future: F)
where
    F: Future<Output = ()> + 'static,
{
    let owned: LocalBoxFuture<()> = Box::pin(future);
    with_node(|n| {
        let future = LocalFutureObj::new(owned);
        n.spawn_pool
            .spawner()
            .spawn_local_obj(future)
            .expect("Failed to spawn future.");
    });
}