Struct StreamWatchdog 

pub struct StreamWatchdog {
    pub enabled: bool,
    pub idle_timeout_ms: u64,
    pub warning_threshold_ms: u64,
    pub aborted: bool,
    pub watchdog_fired_at: Option<u128>,
}

Manages the stream idle timeout watchdog. Matches TypeScript’s streamIdleTimer/streamIdleWarningTimer logic.

Fields

enabled: bool

Whether the watchdog is enabled

idle_timeout_ms: u64

Idle timeout in milliseconds

warning_threshold_ms: u64

Warning threshold in milliseconds

aborted: bool

Whether the stream was aborted by the watchdog

watchdog_fired_at: Option<u128>

When the watchdog fired (performance.now() snapshot)

Implementations

impl StreamWatchdog

pub fn new(enabled: bool, idle_timeout_ms: u64) -> Self

pub fn from_env() -> Self

pub fn is_aborted(&self) -> bool

Check if the watchdog has aborted the stream

pub fn watchdog_fired_at(&self) -> Option<u128>

Get when the watchdog fired (for measuring abort propagation delay)

pub fn fire(&mut self) -> String

Mark the watchdog as having fired (called by the actual timeout logic). Returns the abort reason message.

pub fn warning_message(&self) -> String

Log warning when stream has been idle for half the timeout