Struct microasync_util::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 5)

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.

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

Adds a new future to the queue to be completed.

pub fn push(&mut self, future: impl Future<Output = ()> + 'static) -> &mut Self

Adds a new future to the queue to be completed.

Examples found in repository

examples/tcp.rs (line 15)

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

async fn go(addr: (&str, u16)) {
    let mut listener = TcpListener::bind(addr).unwrap();
    loop {
        get_current_runtime()
            .await
            .push(handle(accept(&mut listener).await.unwrap()));
    }
}

examples/recursion.rs (line 6)

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

async fn print_something_after_ms(ms: u64) {
    wait_ms(ms).await;
    println!("something after {ms}ms! :D");
    get_current_runtime()
        .await
        .push(print_something_after_ms(ms + 1));
}

examples/runtime.rs (line 7)

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

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.