📜  Node.js stream.Readable.from() 方法

📅  最后修改于: 2022-05-13 01:56:48.542000             🧑  作者: Mango

Node.js stream.Readable.from() 方法

stream.Readable.from() 方法是 Stream 模块的内置应用程序编程接口,用于从迭代器中构造可读流。

句法:

stream.Readable.from( iterable, options )

参数:此方法接受上面提到的两个参数,如下所述:

  • iterable:它是一个实现 Symbol.asyncIterator 或 Symbol.iterator可迭代协议的对象。
  • options:它是提供给新 stream.Readable([options]) 的选项。默认情况下,Readable.from() 方法会将 options.objectMode 设置为 true,除非它没有手动设置为 false。

返回值:它返回stream.Readable

下面的例子说明了 Node.js 中stream.Readable.from() 方法的使用:

示例 1:

// Node.js program to demonstrate the     
// stream.Readable.from() method
  
// Constructing readable from stream
const { Readable } = require('stream');
  
// Using async function
async function * generate() {
  yield 'GfG';
  yield 'CS-Portal...';
}
// Using stream.Readable.from() method
const readable = Readable.from(generate());
  
// Handling data event
readable.on('data', (chunk) => {
  console.log(chunk);
});
console.log("Program completed!!");

输出:

Program completed!!
GfG
CS-Portal...

示例 2:

// Node.js program to demonstrate the     
// stream.Readable.from()
// method
  
// Constructing readable from stream
const { Readable } = require('stream');
  
// Using async function
async function * generate() {
  yield 'Nidhi';
  yield 'GeeksforGeeks';
}
// Using stream.Readable.from() method
const readable = Readable.from(generate());
  
// Handling data event
readable.on('data', (chunk) => {
  console.log(chunk.length);
});
console.log("Program completed!!");

输出:

Program completed!!
5
13

参考: https://nodejs.org/api/stream.html#stream_stream_readable_from_iterable_options