import Stream from './Stream'; import Tuple from './Tuple'; declare type NewReceiverFunc = () => Stream; export declare function combineStreams(output: Stream): NewReceiverFunc; export declare function joinNStreams(count: number, joinedOutput: Stream): any[]; export declare function joinNStreams_v2(count: number, joinedOutput: Stream): Stream; export declare function streamPostFilter(stream: Stream, filter: (t: Tuple) => boolean): { next(t: Tuple): void; done(): void; }; export declare function streamPostModify(stream: Stream, callback: (t: Tuple) => Tuple | null): { next(t: Tuple): void; done(): void; }; export declare function streamPostRemoveAttr(stream: Stream, attr: string): { next(t: Tuple): void; done(): void; }; export {};