monitor.rs

#[tokio::main]
async fn main() {
    eprintln!("all positive {:?}", run(&vec![1, 2, 10]).await);
    eprintln!("some negative {:?}", run(&vec![1, 2, -3, 10]).await);
}

/// Run the simulated journal.
pub async fn run(inputs: &Vec<i32>) -> anyhow::Result<()> {
    moro::async_scope!(|scope| {
        for input in inputs {
            let _ = scope.spawn(validate(input)).or_cancel(scope);
        }
        Ok(())
    })
    .await
}

pub async fn validate(input: &i32) -> anyhow::Result<()> {
    if *input < 0 {
        anyhow::bail!("input out of range: {input}");
    }
    Ok(())
}

#[tokio::test]
async fn all_positive() {
    assert!(run(&vec![1, 2, 10]).await.is_ok());
}

#[tokio::test]
async fn some_negative() {
    match run(&vec![1, 2, -3, 10]).await {
        Err(_) => (),
        Ok(()) => panic!("expected an error"),
    }
}