import { serve } from '@hono/node-server'
import { Hono } from 'hono'
import { streamSSE } from 'hono/streaming'
const app = new Hono()
app.get('/test', (c) => {
c.header('Content-Type', 'text/event-stream')
c.header('Cache-Control', 'no-cache')
c.header('Connection', 'keep-alive')
return streamSSE(
c,
(stream) =>
new Promise((resolve) => {
console.log('connected')
stream.onAbort(() => {
console.log('disconnected')
})
}),
)
})
serve(
{
port: 4000,
hostname: '0.0.0.0',
fetch: app.fetch,
},
(info) => {
console.log(`Listening on port ${info.port}`)
},
)
import { serve } from '@hono/node-server'
import { Hono } from 'hono'
import { streamSSE } from 'hono/streaming'
const app = new Hono()
app.get('/test', (c) => {
c.header('Content-Type', 'text/event-stream')
c.header('Cache-Control', 'no-cache')
c.header('Connection', 'keep-alive')
return streamSSE(
c,
(stream) =>
new Promise((resolve) => {
console.log('connected')
stream.onAbort(() => {
console.log('disconnected')
})
}),
)
})
serve(
{
port: 4000,
hostname: '0.0.0.0',
fetch: app.fetch,
},
(info) => {
console.log(`Listening on port ${info.port}`)
},
)