malvin 0.2.4

Non-interactive research and coding agent
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32

#[must_use]
pub fn test_post_teardown_poll_interval() -> std::time::Duration {
    if crate::acp::test_no_real_agent_enabled() {
        std::time::Duration::from_millis(1)
    } else {
        std::time::Duration::from_millis(20)
    }
}

#[must_use]
pub fn test_post_teardown_wait_budget() -> std::time::Duration {
    if crate::acp::test_no_real_agent_enabled() {
        std::time::Duration::from_millis(50)
    } else {
        std::time::Duration::from_millis(500)
    }
}

pub async fn test_wait_until_async<F>(mut condition: F) -> bool
where
    F: FnMut() -> bool,
{
    let deadline = tokio::time::Instant::now() + test_post_teardown_wait_budget();
    let poll = test_post_teardown_poll_interval();
    while tokio::time::Instant::now() < deadline {
        if condition() {
            return true;
        }
        tokio::time::sleep(poll).await;
    }
    condition()
}