better-sse

import { createSession } from 'better-sse'; import express from 'express'; const app = express(); const port = 3000; app.get('/events', (req, res) => { // Ensure client doesn't cache the response res.setHeader('Cache-Control', 'no-cache'); res.setHeader('Content-Type', 'text/event-stream'); res.setHeader('Connection', 'keep-alive'); const session = createSession(req, res); // Optionally, send an initial event session.push('Hello from the server!', 'greeting'); // Periodically send data let counter = 0; const interval = setInterval(() => { if (session.isClosed()) { clearInterval(interval); console.log('Session closed, stopping updates.'); return; } session.push(`Data update ${counter++}`, 'update'); }, 2000); // Handle client disconnect session.on('close', () => { clearInterval(interval); console.log('Client disconnected.'); }); }); app.listen(port, () => { console.log(`SSE server listening at http://localhost:${port}`); console.log('Connect with a browser using EventSource: new EventSource("http://localhost:3000/events")'); });