export class EventStreamWriter {
    #sink;

    static create(opts) {
        const writer = new EventStreamWriter()

        const stream = new ReadableStream({
            type: 'direct',
            async pull(ctrl) {
                writer.#sink = ctrl
            },
        })

        const response = new Response(stream)

        return { writer, response }
    }

    write(message) {
        console.info('write message:', message = `event: ${message.event}\n\n`)
        message = new TextEncoder().encode(message)
        this.#sink.write(message)
        this.#sink.flush()
    }
}



const server = Bun.serve({
    async fetch(req) {
        const { writer, response } = EventStreamWriter.create({})

        setTimeout(async () => {
            let i = 3
            while (i--) {
                writer.write({event: "hello "+ i})
                await Bun.sleep(1000)
            }
        }, 1000)
        
        return response
    },
})

console.info(`Server started on ${server.url}`)





//// TEST
let response = await fetch(server.url)
let chunk, reader = response.body.getReader();

console.info('[JS]', {status: response.status})

while ((chunk = await reader.read()).value) {
  console.info({value: new TextDecoder().decode(chunk.value).slice(0, 30)})
}