1 | import { AbortableAsyncMapper } from '@naturalcycles/js-lib';
|
2 | import { TransformLogProgressOptions, TransformMapOptions } from '../..';
|
3 | export interface NDJSONStreamForEachOptions<IN = any> extends TransformMapOptions<IN, void>, TransformLogProgressOptions<IN> {
|
4 | inputFilePath: string;
|
5 | }
|
6 | /**
|
7 | * Convenience function to `forEach` through an ndjson file.
|
8 | */
|
9 | export declare function ndjsonStreamForEach<T>(mapper: AbortableAsyncMapper<T, void>, opt: NDJSONStreamForEachOptions<T>): Promise<void>;
|