示例 ReadableStream

\Example ReadableStream

此示例创建一个简单的 ReadableStream,它永远每秒推送一次当前的 performance.now() 时间戳。异步迭代器用于从流中读取数据。

\This example creates a simple ReadableStream that pushes the current performance.now() timestamp once every second forever. An async iterable is used to read the data from the stream.

import {
 ReadableStream,
} from 'node:stream/web';
import {
 setInterval as every,
} from 'node:timers/promises';
import {
 performance,
} from 'node:perf_hooks';
const SECOND = 1000;
const stream = new ReadableStream({
 async start(controller) {
 for await (const _ of every(SECOND))
 controller.enqueue(performance.now());
 },
});
for await (const value of stream)
 console.log(value);const {
 ReadableStream,
} = require('node:stream/web');
const {
 setInterval: every,
} = require('node:timers/promises');
const {
 performance,
} = require('node:perf_hooks');
const SECOND = 1000;
const stream = new ReadableStream({
 async start(controller) {
 for await (const _ of every(SECOND))
 controller.enqueue(performance.now());
 },
});
(async () => {
 for await (const value of stream)
 console.log(value);
})();拷贝