export type CollectResult<T> = T extends ArrayBufferView ? T : T extends string ? string : T[];
export declare class EnhancedStream<T> {
    readonly readable: ReadableStream<T>;
    constructor(readable: ReadableStream<T>);
    map<U>(fn: (item: T) => U | Promise<U>): EnhancedStream<U>;
    filter(predicate: (item: T) => boolean | Promise<boolean>): EnhancedStream<T>;
    /**
     * Side effects.
     */
    forEach(fn: (item: T) => void | Promise<void>): EnhancedStream<T>;
    take(n: number): EnhancedStream<T>;
    skip(n: number): EnhancedStream<T>;
    scan<U>(fn: (acc: U, item: T) => U | Promise<U>, initial: U): EnhancedStream<U>;
    reduce<U>(fn: (acc: U, item: T) => U | Promise<U>, initial: U): Promise<U>;
    find(predicate: (item: T) => boolean | Promise<boolean>): Promise<T | undefined>;
    some(predicate: (item: T) => boolean | Promise<boolean>): Promise<boolean>;
    every(predicate: (item: T) => boolean | Promise<boolean>): Promise<boolean>;
    toArray(): Promise<T[]>;
    collect(): Promise<CollectResult<T>>;
    toStream(): ReadableStream<T>;
}
export interface SFunction {
    <T>(readable: ReadableStream<T>): EnhancedStream<T>;
    from<T>(iterable: Iterable<T> | AsyncIterable<T>): EnhancedStream<T>;
}
/**
 * Wrap a ReadableStream with array-like chainable methods.
 */
export declare const S: SFunction;
//# sourceMappingURL=index.d.ts.map