Function drain

benchmark/streams/iter-throughput-broadcast.js:116–119

(source)

  // No-op consumer: drain all batches without collecting
  async function drain(source) {
    // eslint-disable-next-line no-unused-vars
    for await (const _ of source) { /* drain */ }
  }

  async function run() {
    const { writer, broadcast: bc } = broadcast();