สตรีมแปลงข้อมูล

TransformStream คืออะไร

โครงสร้าง

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

เมธอดแปลงข้อมูล

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);
  }
});

ตรวจสอบความเข้าใจ

ทบทวน: สตรีมแปลงข้อมูล