Skip to main content

EXEC_STREAMS

Static EXEC_STREAMS 

Source
pub static EXEC_STREAMS: LazyLock<DashMap<String, StreamEntry>>
Expand description

流式任务表:SSE handler 用 task_id 取出 receiver(一次性,取出即移除)。

后台 task 持有对应的 sender,run_in_container_stream 推 chunk。前端连 SSE 时取走 receiver;若前端从不连接(或连接失败),entry 由 gc_old_tasks 按 TTL 回收,避免 receiver 泄漏。