Module sse-plugin/src

Example

import { SsePlugin } from '@setu-ts/sse-plugin';
import { CAPABILITIES, ISseService } from '@setu-ts/common';

const app = createApplication();
app.register(SsePlugin({ heartbeatMs: 15000, retryMs: 3000 }));
await app.start({ port: 3000 });

app.router.get('/events', async (ctx) => {
  const sse = ctx.services.get<ISseService>(CAPABILITIES.SSE);
  const conn = sse.open(ctx);
  conn.send({ id: '1', data: 'hello world' });
  return conn.result;
});