Function pipeEachLine

npm_modules/cli/test/helpers/StreamHelpers.ts:15–21

(source: AsyncGenerator<Buffer | string>)

}

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

/**
 * Reads the input of source and calls `fn` for each line as a side-effect.