import type { AgentProcess } from './types.js';
import type { NormalizedEvent } from './normalize/event-types.js';
export interface EventObserver {
    onEvent(event: NormalizedEvent): void;
    onClose?(): void | Promise<void>;
}
export interface RunEventTee {
    dispatch(event: NormalizedEvent): void;
    close(): Promise<void>;
}
export declare function createRunEventTee(proc: AgentProcess, observers: EventObserver[], requiredSinks: EventObserver[]): RunEventTee;
export declare function createProcessCloser(proc: AgentProcess): () => Promise<void>;
export declare function settleEventfulRun<T>(resultPromise: Promise<T>, eventLoop: Promise<void>, closeTee: () => Promise<void>, closeProcess: () => Promise<void>): Promise<T>;
export interface ConsumeEventStreamOptions {
    proc: AgentProcess;
    tee: RunEventTee;
    onEvent(event: NormalizedEvent): void | Promise<void>;
}
export declare function consumeEventStream(options: ConsumeEventStreamOptions): Promise<void>;