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