Eai.ResultCollector (eai v0.1.5)

Copy Markdown

基于镜像双倍回显(奇偶校验)的无状态流式收集器。 只截取第 2 次 START 和第 2 次 END 之间的纯净执行结果。 同时提供超时提醒窗口(深度计数器)和中断标记(文件管道)机制。

Summary

Functions

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

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

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

设置强制中断标记

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

Functions

check_and_clear_interrupt_flag(agent_id)

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

check_timeout_window(agent_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(agent_id)

设置强制中断标记

trigger_timeout_window(agent_id, depth \\ 1)

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