import type { Response, StreamEvent } from '@wrongstack/core/types';
/**
 * Consume an `AsyncIterable<StreamEvent>` and reduce it to a non-streaming
 * `Response`. Used by `Provider.complete()` default impls so that the
 * streaming code path is the single source of truth.
 *
 * Optional `onEvent` callback fires for every event as it arrives, useful
 * for the agent loop to emit text_delta to the EventBus without writing
 * its own aggregation logic.
 */
export declare function aggregateStream(stream: AsyncIterable<StreamEvent>, onEvent?: ((e: StreamEvent) => void) | undefined): Promise<Response>;
//# sourceMappingURL=aggregate.d.ts.map