| 1 | import { ReadableTyped } from '../stream.model'
|
| 2 | import { pipelineToNDJsonFile, PipelineToNDJsonFileOptions } from './pipelineToNDJsonFile'
|
| 3 |
|
| 4 | export async function streamToNDJsonFile<IN>(
|
| 5 | stream: ReadableTyped<IN>,
|
| 6 | opt: PipelineToNDJsonFileOptions,
|
| 7 | ): Promise<void> {
|
| 8 | await pipelineToNDJsonFile([stream], opt)
|
| 9 | }
|