minus 5.0.0-alpha2

An asynchronous paging library for Rust
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22

use minus::error::MinusError;
use std::time::Duration;
use tokio::{join, spawn, time::sleep};

#[tokio::main]
async fn main() -> Result<(), MinusError> {
    let output = minus::Pager::new();

    let increment = async {
        for i in 0..=10_u32 {
            output.push_str(&format!("{}\n", i))?;
            sleep(Duration::from_millis(100)).await;
        }
        output.send_message("No more output to come")?;
        Result::<_, MinusError>::Ok(())
    };

    let (res1, res2) = join!(spawn(minus::async_paging(output.clone())), increment);
    res1.unwrap()?;
    res2?;
    Ok(())
}