stream-worker.ts

function sleep(ms: number) {
  return new Promise((resolve) => setTimeout(resolve, ms));
}

export default {
  async fetch(): Promise<Response> {
    // a simple streaming response

    const encoder = new TextEncoder();

    return new Response(
      new ReadableStream({
        async pull(controller) {
          for (let i = 0; i < 5; i++) {
            controller.enqueue(encoder.encode(`Hello world: ${i}\n`));
            await sleep(1000);
          }
          controller.close();
        },
      }),
      {
        status: 200,
        headers: {
          "content-type": "text/plain", // this will buffer on chrome
          // "content-type": "text/x-unknown", // this will not,
          
          // some otehr explicit headers just in case
          "content-encoding": "identity",
          "transfer-encoding": "chunked",
        },
      }
    );
  },
};