export default factory;
export type ForEachOptions = Pick<import('barnard59-core').Context, 'createPipeline' | 'variables'> & {
    pipeline: PipelineStream;
    variable: string;
};
export type PipelineStream = import('stream').Duplex & {
    pipeline: import('barnard59-core').Pipeline;
};
/**
 * @this {import('barnard59-core').Context}
 * @param {PipelineStream} pipeline
 * @param {string} variable
 * @return {ForEach}
 */
declare function factory(this: import("barnard59-core").Context, pipeline: PipelineStream, variable: string): ForEach;
declare class ForEach extends stream.Duplex {
    /**
     * @param {ForEachOptions} context
     */
    constructor({ createPipeline, pipeline, variable, variables }: ForEachOptions);
    _read(): Promise<boolean | undefined>;
    /**
     * @param {*} chunk
     * @param {string} encoding
     * @param {(error?: (Error | null)) => void} callback
     */
    _write(chunk: any, encoding: string, callback: (error?: (Error | null)) => void): Promise<void>;
    createPipeline: (ptr: import("clownface").GraphPointer, arg?: Partial<import("barnard59-core").PipelineOptions> | undefined) => import("barnard59-core").Pipeline;
    ptr: import("clownface").GraphPointer;
    variable: string;
    variables: Map<string, unknown>;
    pull: ReadableToReadable.ReadFunction | null;
    set subPipeline(subPipeline: import("barnard59-core").Pipeline);
    /**
     * @type import('barnard59-core').Pipeline
     */
    get subPipeline(): import("barnard59-core").Pipeline;
}
import stream from 'readable-stream';
import ReadableToReadable from 'readable-to-readable';