نقل البيانات بين Streams بإستخدام pipeline

ال pipeline بتوصل تدفق القراءة بالكتابة وبتتعامل مع الضغط العكسي وأخطاء السلسلة

تجهيز المثال

إستخدم Node.js 24 أو إصدار أحدث متوافق واحفظ الملفات داخل مجلد تدريب جديد وشغل node main.mjs

كود التطبيق

import { Readable, Writable } from 'node:stream';
import { pipeline } from 'node:stream/promises';
let result = '';
const output = new Writable({
  write(chunk, encoding, callback) {
    result += chunk.toString();
    callback();
  },
});
await pipeline(Readable.from(['Hello ', 'Streams']), output);
console.log(result);

طريقة التجربة والنتيجة

الأجزاء بتنتقل إلى Writable وبتظهر مجمعة بعد اكتمال pipeline

ملحوظة

تجميع النتيجة هنا للتوضيح ومع البيانات الكبيرة اكتب إلى ملف أو وجهة تدعم التدفق