Function eachLine

npm_modules/cli/test/helpers/StreamHelpers.ts:1–13

(chunkOrString: Buffer | string)

export function* eachLine(chunkOrString: Buffer | string): Generator<Buffer | string> {
  let position = 0;
  const chunk = typeof chunkOrString === 'string' ? Buffer.from(chunkOrString) : chunkOrString;
  while (position < chunk.length) {
    const newline = chunk.indexOf('\n', position);
    if (newline === -1) {
      yield chunk.subarray(position).toString('utf8') + '\n';
      break;
    }
    yield chunk.subarray(position, newline).toString('utf8') + `\n`;
    position = newline + 1;
  }
}

export async function* pipeEachLine(source: AsyncGenerator<Buffer | string>): AsyncGenerator<Buffer | string> {
  for await (const chunk of source) {