chronaxis.fast.stream
流式读取单文件并产出当前帧贡献，不维护跨帧信号或最终累计。
输入为已编译声明和DBC；输出(time_ns, 原记录序号, 计算项贡献tuple)。 只保存当前帧，文件关闭后才提供最终计数。父会话负责顺序和结果发布。
这是模块参考。日常调用先查公开API索引；下划线对象和嵌套函数供维护者查阅。签名来自固定源码，公开类构造签名经实际Python接口核对。
相关类型
对象导航
| 对象 | 用途 |
|---|---|
FileContributions |
持有一个读取器和有限公式组；同帧仅解码一次，计数按计算项隔离。 |
FileContributions.__init__ |
打开单文件。 |
FileContributions._measured |
仅诊断运行计量解析迭代。 |
FileContributions._selected_time |
确定ASC精确时间检查集合。 |
FileContributions.__iter__ |
返回自身。 |
FileContributions.__next__ |
跳过无关帧并返回一条目标贡献。 |
FileContributions.summary |
取得关闭后的文件事实。 |
FileContributions.close |
关闭本读取器及未返回的实际来源子所有者，失败保留原对象供重试。 |
导入与重导出来源（展开）
from pathlib import Path
from time import perf_counter
from ..results.budget import _cleanup_owner
from ..legacy.decode_policy import check_decode_length
from ..timebase.conversion import convert_time, checked_add_ns
from .can_io import _prepare, _UNSUPPORTED_FDFileContributions
持有一个读取器和有限公式组；同帧仅解码一次，计数按计算项隔离。
FileContributions(spec, database, cancel=None, budget=None, *, _programs_checked=False)源码：src/chronaxis/fast/stream.py:17（行号属于 8904c2f744951857659abd40aaa3535d57faf53c）。
FileContributions.__init__
打开单文件。
FileContributions.__init__(spec, database, cancel=None, budget=None, *, _programs_checked=False)参数
| 名称 | 数据类型 | 必填 | 省略时的值 | 用途、取值和效果 |
|---|---|---|---|---|
spec |
dict | 是 | 无 | 位置或关键字。本次已编译会话或单文件声明，包含来源、公式、顺序和执行资源；调用过程不改写它。 |
database |
cantools.database.Database | 是 | 无 | 位置或关键字。已加载的DBC定义，可在本进程复用；省略时由会话加载，不能与冻结声明冲突。 |
cancel |
Event | None | 否 | None | 位置或关键字。调用方取消事件；is_set为真时停止继续读取或调度，None表示没有外部取消信号。 |
budget |
ResourceBudget | 否 | None | 位置或关键字。本次会话共享的受管理资源用量记录；先预约空间，再构造缓冲或暂存。 |
_programs_checked |
bool | 否 | False | 仅关键字。仅由内部调用传入的公式已检查标志；默认 False，普通入口仍核对原始公式和指令，不读取配置中的同名值。 |
返回说明
迭代器。
异常说明
配置、文件或DBC错误；已取得的读取器在后续构造失败时清理。 ASC/BLF共用各自文件owner；第三方BLF文件头构造失败也保留实际文件关闭责任。 _programs_checked只供已完成公式准备的内部调用；普通调用仍检查原公式。
源码：src/chronaxis/fast/stream.py:20（行号属于 8904c2f744951857659abd40aaa3535d57faf53c）。
FileContributions._measured
仅诊断运行计量解析迭代。
FileContributions._measured(iterator)参数
| 名称 | 数据类型 | 必填 | 省略时的值 | 用途、取值和效果 |
|---|---|---|---|---|
iterator |
Iterator | 是 | 无 | 位置或关键字。底层ASC/BLF原始记录迭代器；诊断包装只计量每次读取，不修改记录。 |
返回说明
原记录生成器。
异常说明
原错误。 正式执行不使用此包装，避免每条原始报文计时开销。
源码：src/chronaxis/fast/stream.py:76（行号属于 8904c2f744951857659abd40aaa3535d57faf53c）。
FileContributions._selected_time
确定ASC精确时间检查集合。
FileContributions._selected_time(frame)参数
| 名称 | 数据类型 | 必填 | 省略时的值 | 用途、取值和效果 |
|---|---|---|---|---|
frame |
can.Message | 是 | 无 | 位置或关键字。当前原始CAN帧，用通道、ID和实际帧型判断是否需要时间顺序检查。 |
返回说明
bool。
异常说明
无。 范围过滤前选择，零贡献和方向不影响集合；无时间消费者不加强检查。
源码：src/chronaxis/fast/stream.py:90（行号属于 8904c2f744951857659abd40aaa3535d57faf53c）。
FileContributions.__iter__
返回自身。
FileContributions.__iter__()参数：无显式参数。
参数说明
无。
返回说明
当前迭代器。
异常说明
无。
源码：src/chronaxis/fast/stream.py:98（行号属于 8904c2f744951857659abd40aaa3535d57faf53c）。
FileContributions.__next__
跳过无关帧并返回一条目标贡献。
FileContributions.__next__()参数：无显式参数。
参数说明
无。
返回说明
时间/序号/贡献元组。
异常说明
解析、时间、解码、公式错误或取消；EOF在读取资源成功关闭后抛出。
源码：src/chronaxis/fast/stream.py:102（行号属于 8904c2f744951857659abd40aaa3535d57faf53c）。
FileContributions.summary
取得关闭后的文件事实。
FileContributions.summary()参数：无显式参数。
参数说明
无。
返回说明
有限dict。
异常说明
未成功EOF时拒绝。
源码：src/chronaxis/fast/stream.py:169（行号属于 8904c2f744951857659abd40aaa3535d57faf53c）。
FileContributions.close
关闭本读取器及未返回的实际来源子所有者，失败保留原对象供重试。
FileContributions.close()参数：无显式参数。
参数说明
无。
返回说明
None。
异常说明
原关闭错误；失败继续保留实际owner供重试。
源码：src/chronaxis/fast/stream.py:177（行号属于 8904c2f744951857659abd40aaa3535d57faf53c）。