0

我正在使用 multer 将文件存储在内存中，其想法是读取缓冲区并逐行检查文件的内容，当一行未通过验证时，我想丢弃否则保存到磁盘。

该文件是一个 csv 文件，我已经尝试过createReadStream，但由于缓冲区失败，所以我使用了 node stream。

我在这个实现中遇到的问题是我无法返回并停止任何来自Readable stream

Readable.from(buffer)
  .pipe(csv())
  .on('data', (data) => {
    if (data.value > 10) {
      return 'Stop the reading of the file I dont want it anymore'
    }
  })
4

0 回答 0