push([...transforms][, options])

• ...transforms <Function> | <Object> 可选转换应用于可读侧。
• options <Object>
  • highWaterMark <number> 在应用回压之前的最大缓冲槽数。必须 >= 1；小于 1 的值将被限制为 1。默认值： 4。
  • backpressure <string> 背压策略：'strict'、'block'、'drop-oldest' 或 'drop-newest'。默认：'strict'。
  • signal <AbortSignal> 中止流。
• 返回：<Object>
  • writer PushWriter 作家的方面。
  • readable AsyncIterable 可读的一面。

创建一个具有背压的推流。写入器推送数据；可读端作为异步可迭代对象被消费。

🌐 Create a push stream with backpressure. The writer pushes data in; the readable side is consumed as an async iterable.

import { push, text } from 'node:stream/iter';

const { writer, readable } = push();

// Producer and consumer must run concurrently. With strict backpressure
// (the default), awaited writes block until the consumer reads.
const producing = (async () => {
  await writer.write('hello');
  await writer.write(' world');
  await writer.end();
})();

console.log(await text(readable)); // 'hello world'
await producing;const { push, text } = require('node:stream/iter');

async function run() {
  const { writer, readable } = push();

  // Producer and consumer must run concurrently. With strict backpressure
  // (the default), awaited writes block until the consumer reads.
  const producing = (async () => {
    await writer.write('hello');
    await writer.write(' world');
    await writer.end();
  })();

  console.log(await text(readable)); // 'hello world'
  await producing;
}

run().catch(console.error);拷贝

写入器返回 push() 符合 [Writer 接口][]。

🌐 The writer returned by push() conforms to the [Writer interface][].