import { type OmpRpcInboundFrame } from './rpc-protocol'; import type { OmpRpcChannel } from './rpc-driver-channel'; import { type DriverState, type OmpRpcTaskHooks, type OmpRpcTaskRequest } from './rpc-driver-state'; import type { OutputEvent } from '../types'; interface DispatchContext { readonly request: OmpRpcTaskRequest; readonly hooks: OmpRpcTaskHooks; readonly state: DriverState; readonly channel: OmpRpcChannel; readonly spawnHook: Promise; readonly pushEvent: (event: OutputEvent) => void; readonly fail: (stopReason: string, message: string) => void; readonly agentEnd: () => void; } export declare class OmpRpcDispatcher { private readonly context; constructor(context: DispatchContext); enqueue(frame: OmpRpcInboundFrame): void; private failFrom; private dispatchReadyFrame; private negotiateAndPrompt; private handlePromptResultFrame; private handleSessionInfoUpdate; private dispatchFrame; } export {}; //# sourceMappingURL=rpc-driver-dispatch.d.ts.map