streamConsumers.json(stream)

• stream <ReadableStream> | <stream.Readable> | <AsyncIterator>

• 返回:<Promise> 将流的内容解析为 UTF-8 编码字符串,然后通过 JSON.parse() 传递。

  \Returns: <Promise> Fulfills with the contents of the stream parsed as a UTF-8 encoded string that is then passed through JSON.parse().

import { json } from 'node:stream/consumers';
import { Readable } from 'node:stream';
const items = Array.from(
 {
 length: 100,
 },
 () => ({
 message: 'hello world from consumers!',
 }),
);
const readable = Readable.from(JSON.stringify(items));
const data = await json(readable);
console.log(`from readable: ${data.length}`);
// Prints: from readable: 100const { json } = require('node:stream/consumers');
const { Readable } = require('node:stream');
const items = Array.from(
 {
 length: 100,
 },
 () => ({
 message: 'hello world from consumers!',
 }),
);
const readable = Readable.from(JSON.stringify(items));
json(readable).then((data) => {
 console.log(`from readable: ${data.length}`);
 // Prints: from readable: 100
});拷贝