丢弃最新
🌐 Drop-newest
写入操作永不等待。当槽缓冲区已满时,传入的写入会被静 silently丢弃。消费者处理已经缓冲的数据,而不会被新的数据淹没。在限流或在压力下减轻负载时非常有用。
🌐 Writes never wait. When the slots buffer is full, the incoming write is silently discarded. The consumer processes what is already buffered without being overwhelmed by new data. Useful for rate-limiting or shedding load under pressure.
import { push } from 'node:stream/iter';
// Accept up to 10 buffered items; discard anything beyond that
const { writer, readable } = push({
highWaterMark: 10,
backpressure: 'drop-newest',
});const { push } = require('node:stream/iter');
// Accept up to 10 buffered items; discard anything beyond that
const { writer, readable } = push({
highWaterMark: 10,
backpressure: 'drop-newest',
});