我更幸运的是这样使用:

let string = '';
readstream
    .on('data', (buf) => string += buf.toString())
    .on('end', () => console.log(string));

我使用节点v9.11.1, readstream是来自http的响应。回调。

我通常使用这个简单的函数将流转换为字符串:

function streamToString(stream, cb) {
  const chunks = [];
  stream.on('data', (chunk) => {
    chunks.push(chunk.toString());
  });
  stream.on('end', () => {
    cb(chunks.join(''));
  });
}

使用的例子:

let stream = fs.createReadStream('./myFile.foo');
streamToString(stream, (data) => {
  console.log(data);  // data is now my string variable
});

(这个答案是多年前的，当时它是最好的答案。下面有一个更好的答案。我没有跟上node.js，我不能删除这个答案，因为它被标记为“正确的这个问题”。如果你想按下，你想让我做什么?)

关键是使用可读流的数据和结束事件。听下面这些事件:

stream.on('data', (chunk) => { ... });
stream.on('end', () => { ... });

当您收到数据事件时，将新的数据块添加到为收集数据而创建的Buffer中。

当您接收到结束事件时，如果需要，将完成的Buffer转换为字符串。那就做你该做的事。

另一种方法是将流转换为promise(参考下面的示例)，然后使用then(或await)将解析值分配给变量。

function streamToString (stream) {
  const chunks = [];
  return new Promise((resolve, reject) => {
    stream.on('data', (chunk) => chunks.push(Buffer.from(chunk)));
    stream.on('error', (err) => reject(err));
    stream.on('end', () => resolve(Buffer.concat(chunks).toString('utf8')));
  })
}

const result = await streamToString(stream)

我更幸运的是这样使用:

let string = '';
readstream
    .on('data', (buf) => string += buf.toString())
    .on('end', () => console.log(string));

我使用节点v9.11.1, readstream是来自http的响应。回调。

你觉得这个怎么样?

async function streamToString(stream) {
    // lets have a ReadableStream as a stream variable
    const chunks = [];

    for await (const chunk of stream) {
        chunks.push(Buffer.from(chunk));
    }

    return Buffer.concat(chunks).toString("utf-8");
}