SSE Streaming

import { createSSE, sseHeartbeat } from '@axiljs/core'
 
app.get('/events', (req, res) => {
  const sse = createSSE(res)
  const stop = sseHeartbeat(sse, 15000)
 
  sse.send({ message: 'Connected' }, 'connect')
 
  const interval = setInterval(() => {
    if (!sse.isOpen) { clearInterval(interval); stop(); return }
    sse.send({ time: Date.now() }, 'update')
  }, 1000)
})

sse.send(data, 'eventType')
sse.comment('heartbeat')
sse.isOpen
sse.close()

const source = new EventSource('/events')
source.addEventListener('update', (e) => {
  console.log(JSON.parse(e.data))
})