export interface Dispatcher<P> {
    /** Queue an event for the named agent. Returns immediately. */
    dispatch(agentHandle: string, payload: P): void;
    /** Wait for all queued events across all agents to finish. */
    drain(): Promise<void>;
    /** Wait for one agent's queue to finish (useful for shutdown). */
    drainAgent(agentHandle: string): Promise<void>;
}
export declare function createDispatcher<P>(runner: (agentHandle: string, payload: P) => Promise<void>): Dispatcher<P>;
//# sourceMappingURL=dispatcher.d.ts.map