Node to/from web readable conversion

nodeReadableToWebReadable.ts

import { type Readable } from "node:stream";

export function nodeReadableToWebReadable(nodeReadable: Readable): ReadableStream {
  return new ReadableStream({
    start(controller): void {
      nodeReadable.on("data", (chunk) => {
        controller.enqueue(chunk);
      });

      nodeReadable.on("end", () => {
        controller.close();
      });

      nodeReadable.on("error", (err) => {
        controller.error(err);
      });
    },

    cancel(): void {
      nodeReadable.destroy();
    }
  });
}

webReadableToNodeReadable.ts

import { Readable } from "stream";

export function webReadableToNodeReadable(readableStream: ReadableStream): Readable {
  const reader = readableStream.getReader();

  return new Readable({
    async read(): Promise<void> {
      const { done, value } = await reader.read();

      if (done) {
        this.push(null);
      } else {
        this.push(value);
      }
    }
  });
}