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: sh cargo run --example ticker

```rust use std::time::Duration; use tokio::time;

let mut interval = asyncfuse::pollfn( time::interval(Duration::fromsecs(1)), time::Interval::polltick, );

let sleep = asyncfuse::once(time::sleep(Duration::fromsecs(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))); } } } ```

License: MIT/Apache-2.0