如何停止节点js LineOutputStream？

Question

我正在处理一个 csv 文件，当我发现一个验证错误并希望脚本停止处理换行符时。

router.use(upload.single('csv')).route('/agency/:agencyId/properties/import').post(function (req, res) {

  var stream = LineInputStream(fs.createReadStream(req.file.path, {flags: 'r'}));
  stream.setDelimiter("\n");

  stream.on('line', function(line) {
    var row = line.split(',');
    if (row.length!=15) {
      stream.end(); // this does not stop the processing of new lines
      return res.status(400).json({error: 'File should have 15 columns.'});
    }
  });

});

Answer 1

在行处理函数中使用stream.destroy()，然后将错误处理程序附加到返回错误响应的流。

参考How to close a readable stream (before end)?