• 返回: {AsyncIterator} 用于完全地消费流。
    1. const fs = require('fs');
    2. async function print(readable) {
    3. readable.setEncoding('utf8');
    4. let data = '';
    5. for await (const chunk of readable) {
    6. data += chunk;
    7. }
    8. console.log(data);
    9. }
    10. print(fs.createReadStream('file')).catch(console.error);

    如果循环以 breakthrow 终止,则流将会被销毁。 换句话说,迭代流将完全地消费流。 将以大小等于 highWaterMark 选项的块读取流。 在上面的代码示例中,如果文件的数据少于 64KB,则数据将位于单个块中,因为没有为 [fs.createReadStream()] 提供 highWaterMark 选项。