streams

The streams built-in module is available to use in your EdgeWorkers code bundles. It exports implementations of ByteLengthQueuingStrategy, CountQueuingStrategy, ReadableStream, TransformStream, and WritableStream, as described in the WhatWG stream specification.

import { createResponse } from 'create-response';
import { httpRequest } from 'http-request';
import { ReadableStream, WritableStream } from 'streams';
import { TextEncoderStream, TextDecoderStream } from 'text-encode-transform';
class UppercaseStream {
  constructor () {
    let readController = null;
    this.readable = new ReadableStream({
      start (controller) {
        readController = controller;
      }
    });
    this.writable = new WritableStream({
      write (text) {
        readController.enqueue(text.toUpperCase());
      },
      close (controller) {
        readController.close();
      }
    });
  }
}
export async function responseProvider (request) {
  const response = await httpRequest('http://example.com/javascripts/jquery-3.3.1.min.js');
  return createResponse(
    response.status,
    {},
    response.body
      .pipeThrough(new TextDecoderStream())
      .pipeThrough(new UppercaseStream())
      .pipeThrough(new TextEncoderStream())
  );
}