التدفقات والضغط العكسي

import { Readable, Transform, Writable } from 'node:stream';
import { pipeline } from 'node:stream/promises';
const collected = [];
await pipeline(
  Readable.from(['ab', 'cd']),
  new Transform({ transform(chunk, encoding, done) { done(null, chunk.toString().toUpperCase()); } }),
  new Writable({ write(chunk, encoding, done) { collected.push(chunk.toString()); done(); } })
);
console.log(collected.join(''));

ABCD

تنقل pipeline المقطعين عبر التحويل ولا تنجح إلا بعد اكتمال الكتابة. يقتصر الجمع على بيانات العرض الصغيرة.

import { Writable } from 'node:stream';
import { once } from 'node:events';
const sink = new Writable({ highWaterMark: 1,
  write(chunk, encoding, done) { setImmediate(done); }
});
const acceptedMore = sink.write(Buffer.from('ab'));
console.log(acceptedMore);
if (!acceptedMore) await once(sink, 'drain');
const finished = once(sink, 'finish');
sink.end(); await finished;
console.log('finished');

false
finished

يتجاوز المقطع ذو البايتين عتبة البايت الواحد. يتيح انتظار drain تفريغ المخزن قبل إنهاء التدفق.