Struct fumio::Runtime

pub struct Runtime { /* fields omitted */ }

Runtime

When running/entered it supports the following subsystems:

• fumio::reactor::current(), also automatically used by fumio::reactor::LazyHandle
• fumio::pool::current_local()
• tokio_timer::timer::TimerHandle::current()

Methods

impl Runtime

pub fn new() -> Result<Self>

Create new runtime

pub fn handle(&self) -> Handle

Handle to the runtime

pub fn spawn<F>(&self, future: F) where
    F: Future<Output = ()> + 'static, 

Spawn future on runtime

pub fn spawn_local_obj(&self, future: LocalFutureObj<'static, ()>)

Spawn future object on runtime

pub fn enter_run_until<F, T>(&mut self, enter: &mut Enter, future: F) -> T where
    F: Future<Output = T>, 

Runs all the tasks in the pool until the given future completes.

The given spawner, spawn, is used as the default spawner for any newly-spawned tasks. You can route these additional tasks back into the LocalPool by using its spawner handle:

The function will block the calling thread only until the future f completes; there may still be incomplete tasks in the pool, which will be inert after the call completes, but can continue with further use of one of the pool's run or poll methods. While the function is running, however, all tasks in the pool will try to make progress.

pub fn run_until<F, T>(&mut self, future: F) -> T where
    F: Future<Output = T>, 

Runs all the tasks in the pool until the given future completes.

The given spawner, spawn, is used as the default spawner for any newly-spawned tasks. You can route these additional tasks back into the LocalPool by using its spawner handle:

The function will block the calling thread only until the future f completes; there may still be incomplete tasks in the pool, which will be inert after the call completes, but can continue with further use of one of the pool's run or poll methods. While the function is running, however, all tasks in the pool will try to make progress.

pub fn enter_run(&mut self, enter: &mut Enter)

Run all tasks in the pool to completion.

The function will block the calling thread until all tasks in the pool completed, including any spawned while running existing tasks.

pub fn run<F, T>(&mut self)

Run all tasks in the pool to completion.

The function will block the calling thread until all tasks in the pool completed, including any spawned while running existing tasks.

Trait Implementations

impl Debug for Runtime

fn fmt(&self, f: &mut Formatter) -> Result

Formats the value using the given formatter.

impl Spawn for Runtime

fn spawn_obj(
    &mut self,
    future: FutureObj<'static, ()>
) -> Result<(), SpawnError>

Spawns a future that will be run to completion.

fn status(&self) -> Result<(), SpawnError>

Determines whether the executor is able to spawn new tasks.

impl LocalSpawn for Runtime

fn spawn_local_obj(
    &mut self,
    future: LocalFutureObj<'static, ()>
) -> Result<(), SpawnError>

Spawns a future that will be run to completion.

fn status_local(&self) -> Result<(), SpawnError>

Determines whether the executor is able to spawn new tasks.