import { toAsyncIterable } from "@ayonli/jsext/reader";

const res = new Response("Hello, World!");

for await (const chunk of toAsyncIterable(res.body!)) {
    console.log("receive chunk:", chunk);
}

import { toAsyncIterable } from "@ayonli/jsext/reader";

// listen to the `onmessage`
const sse = new EventSource("/sse/message");

for await (const msg of toAsyncIterable(sse)) {
    console.log("receive message:", msg);
}

// listen to a specific event
const channel = new EventSource("/sse/broadcast");

for await (const msg of toAsyncIterable(channel, { event: "broadcast" })) {
    console.log("receive message:", msg);
}

import { toAsyncIterable } from "@ayonli/jsext/reader";

const ws = new WebSocket("/ws");

for await (const msg of toAsyncIterable(ws)) {
    if (typeof data === "string") {
        console.log("receive text message:", data);
    } else {
        console.log("receive binary data:", data);
    }
}

import { toAsyncIterable } from "@ayonli/jsext/reader";

for await (const msg of toAsyncIterable(self)) {
    console.log("receive message from the parent window:", msg);
}

import { toAsyncIterable } from "@ayonli/jsext/reader";

for await (const msg of toAsyncIterable(process)) {
    console.log("receive message from the parent process:", msg);
}