import type { StreamPart, TurnHandle } from '../types/stream.js';
export interface EventBus {
    emit(part: StreamPart): void;
    events(): AsyncIterable<StreamPart>;
    close(): void;
}
export declare function createEventBus(): EventBus;
export interface TurnHandleOptions {
    run: () => Promise<import('../types/channel.js').TurnResult>;
    bus: EventBus;
    abortController?: AbortController;
    /** Settles when the run is opened, not when the turn body finishes. */
    runId?: Promise<string>;
}
export declare function createTurnHandle(options: TurnHandleOptions): TurnHandle;