/// <reference types="node" />
import * as nodeStream from 'stream';
import { ParallelOptions, Reader } from './reader';
export declare class Writer<T> {
    write: (this: Writer<T>, value?: T) => this;
    ended: boolean;
    constructor(write: (value: T) => void, stop?: (arg?: any) => void);
    writeAll(val: T): this;
    stop(arg?: any): Writer<T>;
    end(): this;
    get pre(): Pre<T>;
    nodify(): nodeStream.Writable;
    get result(): any;
}
export declare function create<T>(write: (value: T) => Writer<T>, stop?: (arg?: any) => Writer<T>): Writer<T>;
export declare class PreImpl<T> {
    writer: Writer<T>;
    constructor(writer: Writer<T>);
}
export interface Pre<T> extends PreImpl<T> {
    map<U>(fn: (elt: U, index?: number) => T): Writer<U>;
    tee(writer: Writer<T>): Writer<T>;
    concat(readers: Reader<T>[]): Writer<T>;
    transform<U>(fn: (reader: Reader<U>, writer: Writer<T>) => void): Writer<U>;
    filter(fn: (elt: T, index?: number) => boolean): Writer<T>;
    until(fn: (elt: T, index?: number) => boolean): Writer<T>;
    while(fn: (elt: T, index?: number) => boolean): Writer<T>;
    limit(n: number, stopArg?: any): Writer<T>;
    skip(n: number): Writer<T>;
    parallel(options: ParallelOptions | number, consumer: (source: any) => Reader<T>): Writer<T>;
    buffer(max: number): Writer<T>;
    nodeTransform<U>(duplex: nodeStream.Duplex): Writer<U>;
}