import type { StreamState } from "../types/stream";
import type { L0Event } from "../types/l0";
export declare class StreamNormalizer {
    private state;
    private accumulated;
    private checkpointInterval;
    private lastCheckpoint;
    constructor(options?: {
        checkpointInterval?: number;
    });
    private createInitialState;
    normalize(stream: AsyncIterable<any>, signal?: AbortSignal): AsyncGenerator<L0Event>;
    getState(): StreamState;
    getAccumulated(): string;
    getCheckpoint(): string;
    reset(): void;
    private createStreamError;
}
export declare function createStreamNormalizer(options?: {
    checkpointInterval?: number;
}): StreamNormalizer;
export declare function normalizeStreamWithTimeout(stream: AsyncIterable<any>, options?: {
    initialTimeout?: number;
    interTokenTimeout?: number;
    signal?: AbortSignal;
}): AsyncGenerator<L0Event>;
export declare function bufferStream(stream: AsyncIterable<L0Event>, bufferSize?: number): AsyncGenerator<L0Event[]>;
export declare function mapStream<T>(stream: AsyncIterable<L0Event>, mapper: (event: L0Event) => T): AsyncGenerator<T>;
export declare function filterStream(stream: AsyncIterable<L0Event>, predicate: (event: L0Event) => boolean): AsyncGenerator<L0Event>;
export declare function takeStream(stream: AsyncIterable<L0Event>, count: number): AsyncGenerator<L0Event>;
export declare function collectStream(stream: AsyncIterable<L0Event>): Promise<L0Event[]>;
export declare function consumeStream(stream: AsyncIterable<L0Event>): Promise<string>;
export declare function passthroughStream(stream: AsyncIterable<L0Event>): AsyncGenerator<L0Event>;
export declare function tapStream(stream: AsyncIterable<L0Event>, callback: (event: L0Event) => void): AsyncGenerator<L0Event>;
export declare function mergeStreams(...streams: AsyncIterable<L0Event>[]): AsyncGenerator<L0Event>;
export declare function streamFromArray(events: L0Event[]): AsyncGenerator<L0Event>;
export declare function debounceStream(stream: AsyncIterable<L0Event>, delayMs: number): AsyncGenerator<L0Event>;
//# sourceMappingURL=stream.d.ts.map