import { replace } from "web-stream-replace";

const greet = (name: string) => replace("World", name, { output: "string" });

const output = () => {
  let buf = "";
  return new WritableStream<string>({
    write(chunk) {
      buf += chunk;
    },
    close() {
      console.log(buf);
    },
  });
};

const hello = new ReadableStream({
  start(controller) {
    controller.enqueue("Hello, World!");
    controller.close();
  },
});

const transformed = hello.pipeThrough(greet("Netlify"));
await transformed.pipeTo(output());