import type { AgentMessage } from "@oh-my-pi/pi-agent-core";
export interface YieldDispatcher<P> {
    /** Drop entries already delivered through another path. Called per-entry at flush time. */
    isStale?(entry: P): boolean;
    /** Produce one batched AgentMessage from non-stale entries. Return null to skip. */
    build(survivors: P[]): AgentMessage | null;
}
export interface YieldQueueOptions {
    isStreaming: () => boolean;
    injectStreaming(msg: AgentMessage): void;
    injectIdle(messages: AgentMessage[]): Promise<void>;
    scheduleIdleFlush(run: () => Promise<void>): void;
}
type YieldFlushMode = "streaming" | "idle";
export declare class YieldQueue {
    #private;
    constructor(options: YieldQueueOptions);
    register<P>(kind: string, dispatcher: YieldDispatcher<P>): () => void;
    enqueue<P>(kind: string, entry: P): void;
    has(kind?: string): boolean;
    flush(mode: YieldFlushMode): Promise<void>;
    clear(): void;
}
export {};