Eai.ResultCollector (eai v0.1.7)

Copy Markdown

基于单次哨兵匹配的无状态流式收集器。 截取第 1 次 START 和第 1 次 END 之间的纯净执行结果。 (PTY 命令行用 base64 包装哨兵,回显中不再出现明文哨兵,无需奇偶校验。) 同时提供超时提醒窗口(深度计数器)和中断标记(Cache)机制。

Summary

Functions

检查并清除中断标记,返回 true/false

检查当前超时窗口深度。如果 >0,消耗一层并返回提醒消息;否则清除并返回 nil。

超时时强制取出 buffer 中已有的全部数据,尽力提取有效内容后标记完成。

设置强制中断标记

触发超时提醒窗口:在 Cache 中写入超时深度。 每次模型调用 get_task_result 时会消耗一层深度并返回提醒消息。

Functions

check_and_clear_interrupt_flag(pty_session_id)

检查并清除中断标记,返回 true/false

check_timeout_window(pty_session_id)

检查当前超时窗口深度。如果 >0,消耗一层并返回提醒消息;否则清除并返回 nil。

collect(task_id, data)

force_complete(task_id)

超时时强制取出 buffer 中已有的全部数据,尽力提取有效内容后标记完成。

get(task_id)

init_task(task_id)

sentinel_left()

sentinel_right()

set_interrupt_flag(pty_session_id)

设置强制中断标记

trigger_timeout_window(pty_session_id, depth \\ 1)

触发超时提醒窗口:在 Cache 中写入超时深度。 每次模型调用 get_task_result 时会消耗一层深度并返回提醒消息。