Crate async_fuse

Helpers for fusing asynchronous computations.

This is especially useful in combination with optional branches using tokio::select, where the future being polled isn't necessarily set.

A similar structure is provided by futures-rs called Fuse. This however lacks some of the flexibility needed to interact with tokio's streaming types like [Interval] since these no longer implement [Stream].

Examples

This is available as the ticker example:

cargo run --example ticker

use std::time::Duration;
use tokio::time;

let mut interval = async_fuse::poll_fn(
    time::interval(Duration::from_secs(1)),
    time::Interval::poll_tick,
);

let sleep = async_fuse::once(time::sleep(Duration::from_secs(5)));
tokio::pin!(sleep);

for _ in 0..20usize {
    tokio::select! {
        when = &mut interval => {
            println!("tick: {:?}", when);
        }
        _ = &mut sleep => {
            interval.set(time::interval(Duration::from_millis(200)));
        }
    }
}

Structs

Once	Fusing adapter that is capable of polling an interior value that is being fused using a custom polling function.
PollFn	Fusing adapter that is capable of polling an interior value that is being fused using a custom polling function.

Functions

once	Construct a fusing adapter that is capable of polling an interior future.
poll_fn	Construct a fusing adapter that is capable of polling an interior value that is being polled using a custom function.