rho-coding-agent 0.28.1

A lightweight agent harness inspired by Pi
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20

use super::RunCancellation;

#[tokio::test]
async fn cancellation_wakes_current_and_future_waiters() {
    let cancellation = RunCancellation::default();
    let waiter = {
        let cancellation = cancellation.clone();
        tokio::spawn(async move { cancellation.cancelled().await })
    };

    cancellation.cancel();

    tokio::time::timeout(std::time::Duration::from_secs(1), waiter)
        .await
        .expect("current waiter was not notified")
        .expect("waiter task failed");
    tokio::time::timeout(std::time::Duration::from_secs(1), cancellation.cancelled())
        .await
        .expect("future waiter did not observe cancellation");
}