تدفقات التحويل

ما المقصود بـ TransformStream؟

البنية

const ts = new TransformStream();
console.log(ts.writable, ts.readable);

الطريقة transform

const upper = new TransformStream({
  transform(chunk, controller) {
    controller.enqueue(chunk.toUpperCase());
  }
});

مدخل واحد ومخرجات متعددة

const splitter = new TransformStream({
  transform(line, controller) {
    for (const word of line.split(" ")) controller.enqueue(word);
  }
});

التصفية باستخدام التحويلات

const onlyEven = new TransformStream({
  transform(n, controller) {
    if (n % 2 === 0) controller.enqueue(n);
  }
});

الطريقة flush

const ts = new TransformStream({
  transform(c, ctrl) { ctrl.enqueue(c); },
  flush(ctrl) { ctrl.enqueue("[END]"); }
});

التخزين المؤقت عبر الأجزاء

let buffer = "";
new TransformStream({
  transform(chunk, ctrl) {
    buffer += chunk;
    const parts = buffer.split("\n");
    buffer = parts.pop();
    for (const line of parts) ctrl.enqueue(line);
  },
  flush(ctrl) { if (buffer) ctrl.enqueue(buffer); }
});

تدفقات التحويل المضمّنة

const gzip = new CompressionStream("gzip");
const compressed = inputStream.pipeThrough(gzip);

الربط باستخدام pipeThrough

const out = sourceStream
  .pipeThrough(new TextDecoderStream())
  .pipeThrough(upper);

التحويلات غير المتزامنة

new TransformStream({
  async transform(chunk, ctrl) {
    const result = await process(chunk);
    ctrl.enqueue(result);
  }
});

انتشار الأخطاء

new TransformStream({
  transform(chunk, ctrl) {
    if (!valid(chunk)) throw new Error("bad chunk");
    ctrl.enqueue(chunk);
  }
});

اختبار سريع

مراجعة: تدفقات التحويل