Struct AsyncRuntime 

pub struct AsyncRuntime { /* private fields */ }

Implementations

impl AsyncRuntime

pub fn new(threads: usize) -> Self

pub fn with_default_threads() -> Self

pub fn with_wake(threads: usize, wake: WakeFn) -> Self

pub fn spawn_future<T, F, A>(&self, future: F, apply: A) -> TaskHandle

where T: Send + 'static, F: Future<Output = T> + Send + 'static, A: FnOnce(T) + 'static,

pub fn spawn_task<F>(&self, future: F) -> TaskHandle

where F: Future<Output = ()> + Send + 'static,

pub fn spawn_blocking<T, W, A>(&self, work: W, apply: A) -> TaskHandle

where T: Send + 'static, W: FnOnce() -> T + Send + 'static, A: FnOnce(T) + 'static,

pub fn cancel(&self, id: TaskId) -> bool

pub fn spawn_stream<T, F, Make, C>( &self, make_future: Make, on_item: C, ) -> TaskHandle

where T: Send + 'static, F: Future<Output = ()> + Send + 'static, Make: FnOnce(Emitter<T>) -> F + Send + 'static, C: Fn(T) + 'static,

pub fn spawn_to_signal<T, F>(&self, signal: &Signal<T>, future: F) -> TaskHandle

where T: Clone + PartialEq + Send + 'static, F: Future<Output = T> + Send + 'static,

pub fn pending(&self) -> Signal<u64>

pub fn is_busy(&self) -> bool

pub fn threads(&self) -> usize

pub fn drain(&self) -> usize

pub fn drain_until(&self, timeout: Duration) -> usize

Trait Implementations

impl Clone for AsyncRuntime

fn clone(&self) -> Self

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl TestDrain for AsyncRuntime

fn test_drain(&self) -> usize