Fastify plugin for sending Server-sent events.
For fastify@2.x use fastify-sse-v2@1.x!
yarn add fastify-sse-v2
Register fastify-sse-v2 plugin into your fastify instance:
import {FastifySSEPlugin} from "fastify-sse-v2";
const server = fastify();
server.register(FastifySSEPlugin);import {FastifySSEPlugin} from "fastify-sse-v2";
const server = fastify();
server.register(FastifySSEPlugin);
server.get("/", function (req, res) {
res.sse((async function * source () {
for (let i = 0; i < 10; i++) {
sleep(2000);
yield {id: String(i), data: "Some message"};
}
})());
});import {FastifySSEPlugin} from "fastify-sse-v2";
const server = fastify();
server.register(FastifySSEPlugin);
server.get("/", async function (req, res) {
for (let i = 0; i < 10; i++) {
await sleep(2000);
res.sse({id: String(i), data: "Some message"});
}
});
fastify.get('/listenForChanges', {}, (request, reply) => {
const listenStream = fastify.db.watch('doc-uuid')
.on('data', (data)=>reply.sse({ data: JSON.stringify(data) }))
.on('delete', () => reply.sse({ event: 'close' }))
request.socket.on('close', ()=>listenStream.end())
})import {FastifySSEPlugin} from "fastify-sse-v2";
import {on} from "events";
const server = fastify();
server.register(FastifySSEPlugin);
server.get("/", function (req, res) {
res.sse(
(async function* () {
for await (const [event] of on(eventEmmitter, "update")) {
yield {
type: event.name,
data: JSON.stringify(event),
};
}
})()
);
});- to remove event listeners (or some other cleanup) when client closes connection,
you can listen on connection closing event:
request.socket.on('close', () => abortController.abort());