share(source[, options])

• source <AsyncIterable> 共享的来源。
• options <Object>
  • highWaterMark <number> 缓冲区大小。必须 >= 1;小于 1 的值将被限制为 1。默认值: 16。
  • backpressure <string> 'strict'、'block'、'drop-oldest' 或 'drop-newest'。默认值: 'strict'。
• 返回:Share

创建一个拉取模式的多消费者共享流。与 broadcast() 不同,源只有在消费者拉取时才会被读取。多个消费者共享一个缓冲区。

🌐 Create a pull-model multi-consumer shared stream. Unlike broadcast(), the source is only read when a consumer pulls. Multiple consumers share a single buffer.

import { from, share, text } from 'node:stream/iter';
const shared = share(from('hello'));
const c1 = shared.pull();
const c2 = shared.pull();
// Consume concurrently to avoid deadlock with small buffers.
const [r1, r2] = await Promise.all([text(c1), text(c2)]);
console.log(r1); // 'hello'
console.log(r2); // 'hello'const { from, share, text } = require('node:stream/iter');
async function run() {
 const shared = share(from('hello'));
 const c1 = shared.pull();
 const c2 = shared.pull();
 // Consume concurrently to avoid deadlock with small buffers.
 const [r1, r2] = await Promise.all([text(c1), text(c2)]);
 console.log(r1); // 'hello'
 console.log(r2); // 'hello'
}
run().catch(console.error);拷贝