/** * GroupDispatchSession:单个 GroupSession 独享的持久化调度执行边界。 * * 本对象统一拥有调度队列、当前模型取消信号和调度 Turn 状态。调度策略只负责决策, * 不再自行拥有跨 GroupSession 的运行状态或停止语义。 */ import type { GroupDispatchSessionDataStore, GroupDispatchSessionInput, GroupDispatchSessionOptions, GroupDispatchSessionResult } from "../types/group/GroupDispatchSession.js"; /** 主动停止 Dispatch Session 时使用的内部错误。 */ export declare class GroupDispatchStoppedError extends Error { constructor(); } /** GroupSession 私有的调度 Session。 */ export declare class GroupDispatchSession { private readonly dispatch_strategy; private store?; private queue_tail; private active_abort_controller?; private stopping; private disposed; constructor(options: GroupDispatchSessionOptions); /** 绑定持久化视图,并把进程中断留下的运行态明确收口为 stopped。 */ initialize(store: GroupDispatchSessionDataStore): Promise; /** 按提交顺序执行一次调度,并在返回前持久化最终决定。 */ decide(input: GroupDispatchSessionInput): Promise; /** 中断当前模型调用,并让尚未开始的调度 Turn 按队列顺序收口。 */ stop(): Promise; /** 永久释放当前 Dispatch Session。 */ dispose(): Promise; /** 执行队首调度 Turn,确保成功、失败和停止都形成持久化终态。 */ private execute_turn; /** 提交没有 decision 的失败或停止终态。 */ private persist_terminal_turn; private require_store; private assert_available; } //# sourceMappingURL=GroupDispatchSession.d.ts.map