Skip to main content

terminal_stream

agentmux_srv::server::http_viewer_terminal

Function terminal_stream 

Source 
pub(crate) fn terminal_stream(
    source: TermSource,
    last_event_id: Option<u64>,
    lease: FeedLease,
    timing: TermTiming,
    probe: TermProbe,
) -> impl Stream<Item = Result<Bytes, Infallible>> + Send + 'static
Expand description

One terminal feed: retry, a snapshot (or, for a reconnect that still holds, the bytes it missed as one append), then an append per write, size on a resize, reset + snapshot when the file is truncated or the feed loses its place, and a heartbeat on a quiet stream. Ends with reset when the device falls more than 1 MB behind or the terminal may no longer be watched, and silently when the device is revoked or goes away.