Struct microasync_rt::QueuedRuntime

pub struct QueuedRuntime { /* private fields */ }

A very small async runtime, with support for adding more tasks as it runs. This uses a VecDeque internally.

Implementations

impl QueuedRuntime

pub fn new() -> Self

Creates a new, empty QueuedRuntime. Awaiting this does nothing unless futures are pushed to it.

Examples found in repository

examples/tcp.rs (line 14)

fn main() {
    let mut runtime = QueuedRuntime::new();
    runtime.push(go(("0.0.0.0", 5000)));
    sync(runtime);
}

examples/recursion.rs (line 7)

fn main() {
    let mut runtime = QueuedRuntime::new();
    runtime.push(print_something_after_ms(0));
    sync(runtime);
}

examples/runtime.rs (line 5)

fn main() {
    let mut runtime = QueuedRuntime::new();
    for _ in 0..50 {
        runtime.push(print_something_after_ms(2000));
    }
    sync(runtime);
}

pub fn new_with_boxed(future: BoxFuture<'static, ()>) -> Self

Creates a new QueuedRuntime. Unlike new(), this adds a single future immediately, so awaiting this will have an effect.

pub fn new_with(future: impl Future<Output = ()> + 'static) -> Self

Creates a new QueuedRuntime. Unlike new(), this adds a single future immediately, so awaiting this will have an effect.

Trait Implementations

impl Default for QueuedRuntime

fn default() -> Self

Returns the “default value” for a type.

impl Future for QueuedRuntime

type Output = ()

The type of value produced on completion.

fn poll(self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<Self::Output>

Attempt to resolve the future to a final value, registering the current task for wakeup if the value is not yet available.

impl InternalRuntime for QueuedRuntime

fn push_boxed(&mut self, future: BoxFuture<'static, ()>) -> u64

Adds a new future to the queue to be completed.

fn contains(&self, id: u64) -> bool

Returns if a future by some ID is still running.

fn sleep<'b>(&self, duration: Duration) -> BoxFuture<'b, ()>

Asynchronously sleeps

fn stop(&mut self)

Stops the runtime