| 1 | import { pipelineToArray } from './pipeline/pipelineToArray'
|
| 2 | import { ReadableTyped } from './stream.model'
|
| 3 |
|
| 4 | export async function streamJoinToString(
|
| 5 | stream: ReadableTyped<string | Buffer>,
|
| 6 | joinOn = '',
|
| 7 | ): Promise<string> {
|
| 8 | const chunks = await pipelineToArray<string | Buffer>([stream], { objectMode: false })
|
| 9 |
|
| 10 | // eslint-disable-next-line unicorn/no-array-callback-reference
|
| 11 | return chunks.filter(Boolean).map(String).join(joinOn)
|
| 12 | }
|