rho-coding-agent 2.19.0

A fast Rust agent harness with a small footprint and opinionated defaults
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23

use std::time::Duration;

use tokio::sync::watch;

use crate::subagent::RunStatus;

/// The test transfers its only sender to the session. A detached artifact
/// writer retains that sender until its final disk write, so channel closure
/// (not a terminal snapshot) is the condition for reading the complete journal.
pub(crate) async fn wait_for_writer(mut status_rx: watch::Receiver<RunStatus>) -> RunStatus {
    // Match the existing process-session failure bound; this is not a delay.
    const WRITER_COMPLETION_BUDGET: Duration = Duration::from_secs(30);
    let completed = tokio::time::timeout(WRITER_COMPLETION_BUDGET, async {
        while status_rx.changed().await.is_ok() {}
    })
    .await;
    let status = status_rx.borrow().clone();
    assert!(
        completed.is_ok(),
        "artifact writer did not close its status channel within {WRITER_COMPLETION_BUDGET:?}; status: {status:?}"
    );
    status
}