0

大家好，节日快乐！

我正在尝试使用高地的 csv 行流。为了进行一些特殊处理并避免将标头传递给流，我正在调用.consume()，然后我希望将结果放在一个数组中。.toArray()问题是从未调用过的回调。我只是对此感到好奇，因为我已经将解决​​方案更改为，.map().toArray()但我仍然认为.consume()这将是一个更优雅的解决方案。;) 这是从 csv 文件读取并处理行的代码：

const fs = require('fs');
const _ = require('highland');

const dataStream = fs.createReadStream('file.csv', 'utf8');

_(dataStream)
  .split()
  .consume((err, row, push, next) => {
    console.log('consuming a row', row); // <-- this shows data

    if (err) {
      push(err);
      return next();
    }

    // This condition is needed as .consume() passes an extra {} at the end of the stream <-- donno what this happens!!
    if (typeof row !== 'string') {
      return next();
    }

    const cells = row.split(',');

    if (cells[0] === 'CODE') { // <-- header row
      const { columnNames, columnIndexes } = processHeader(cells)); // <-- not relevant, works okay
      return next();
    }

    console.log('processin content here', processRow(cells)); // <-- not relevant, works okay
    push(null, processRow(cells));
    return next();
  })
  .toArray(rows => console.log('ROWS: ', rows)); // <-- I don't get anything here

非常感谢！

4

1 回答 1

0

两者都consume消耗toArray一个流。您只能使用一次流。如果您尝试多次使用它，“流”将为空。

于 2017-12-27T02:08:12.157 回答