Server Sent Events
Hello guys! Sorry if this was asked before. I'm trying to implement an event emitter with SSE like this:
but it seems it goes directly in the onError on frontend because it closes the stream
const emitter = new EventEmitter();
app.use("/sse/*", async (c, next) => {
c.header("Content-Type", "text/event-stream");
c.header("Cache-Control", "no-cache");
c.header("Connection", "keep-alive");
await next();
});
app.post('/message', async (c) => {
const message = 'test';
emitter.emit('message', message);
return c.json({message});
})
app.get('/sse', async (c) => {
return streamSSE(c, async (stream) => {
const handler = async (message: string) => {
await stream.writeSSE({
data: message,
event: "message"
});
}
stream.onAbort(() => {
console.log('Connection aborted');
})
emitter.on('message', handler);
})
})const emitter = new EventEmitter();
app.use("/sse/*", async (c, next) => {
c.header("Content-Type", "text/event-stream");
c.header("Cache-Control", "no-cache");
c.header("Connection", "keep-alive");
await next();
});
app.post('/message', async (c) => {
const message = 'test';
emitter.emit('message', message);
return c.json({message});
})
app.get('/sse', async (c) => {
return streamSSE(c, async (stream) => {
const handler = async (message: string) => {
await stream.writeSSE({
data: message,
event: "message"
});
}
stream.onAbort(() => {
console.log('Connection aborted');
})
emitter.on('message', handler);
})
})but it seems it goes directly in the onError on frontend because it closes the stream
