Function sleep

crates/opencode-provider/src/retry.rs:55–70

Sleep for `ms` milliseconds, returning early if the `cancel` receiver signals `true`.

(ms: u64, mut cancel: watch::Receiver<bool>)

/// Sleep for `ms` milliseconds, returning early if the `cancel` receiver
/// signals `true`.
pub async fn sleep(ms: u64, mut cancel: watch::Receiver<bool>) {
    let capped = ms.min(RETRY_MAX_DELAY);
    let duration = std::time::Duration::from_millis(capped);

    tokio::select! {
        _ = tokio::time::sleep(duration) => {}
        _ = async {
            while !*cancel.borrow_and_update() {
                if cancel.changed().await.is_err() {
                    // Sender dropped – treat as cancellation.
                    return;
                }
            }
        } => {}
    }
}

// ---------------------------------------------------------------------------
// delay – compute how long to wait before the next retry