const server = Bun.serve({
  async fetch(req) {
    const stream = new ReadableStream({
      async start(controller) {
        const encoder = new TextEncoder()
        let count = 0
        const interval = setInterval(() => {
          controller.enqueue(encoder.encode(`${count  }\n`))
        }, 1000)
        let closed = false
        function close() {
          if (closed) return
          console.log('aborted')
          closed = true
          clearInterval(interval)
          req.signal.removeEventListener('abort', close)
          controller.close()
        }
        req.signal.addEventListener('abort', close)
        if (req.signal.aborted) return close()
      }
    })
    return new Response(stream)
  }
})