javascript - Node 流 - 超出最大调用堆栈

Question

我似乎无法弄清楚为什么我的流管道会出现此错误。我想我已经用尽了所有路径，所以我缺少什么:这是我所拥有的:

var myCsvStream = fs.createReadStream('csv_files/myCSVFile.csv');
var csv = require('fast-csv');
var myData = [];

var myFuncs = { 
 parseCsvFile: function (filepath) {

  var csvStream;

  csvStream = csv
  .parse({headers: true, objectMode: true, trim: true})
  .on('data', function (data) {

       myData.push(data);

  })
  .on('end', function () {

    console.log('done parsing counties')
  });

  return csvStream;

 }
}

myCsvStream
.pipe(myFuncs.parseCsvFile())
.pipe(process.stdout);

process.stdout 只是为了让我可以看到数据可以继续到下一个流，但是，当添加 pipe(process.stdout) 甚至through2 双工流 我得到了达到最大调用堆栈的错误。有什么想法吗？

Answer 1

我认为你应该这样写:

var myCsvStream = fs.createReadStream('csv_files/myCSVFile.csv');
var csv = require('fast-csv');

var csvStream = csv
  .parse({headers: true, objectMode: true, trim: true})
  .on('data', function (data) {
    myData.push(data);
  })
  .on('end', function () {
    console.log('done parsing counties')
  });

myCsvStream
.pipe(csvStream)
.pipe(process.stdout);

在您可以将其全部包装在一个函数中之后。