fastify-sse-v2
v4.1.0
Published
Fastify plugin for sending server side events.
Downloads
46,323
Readme
Fastify SSE Plugin
Fastify plugin for sending Server-sent events.
For [email protected]
use [email protected]!
How to use?
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);
Sending events from AsyncIterable source
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" };
}
})()
);
});
Sending individual events
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());
});
Note
- When sending individual events, the connection is kept open until you call
reply.sseContext.source.end()
to terminate the stream.
Sending events from EventEmmiters
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 {
event: event.name,
data: JSON.stringify(event),
};
}
})()
);
});
Note
- 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());
Change server send retry behavior
import { FastifySSEPlugin } from "fastify-sse-v2";
const server = fastify();
server.register(FastifySSEPlugin) // retryDelay default 3000
server.register(FastifySSEPlugin, {
retryDelay: false // disable retryDelay
retryDelay: 5000 // override 5000
})
Note
- You can set parameter
retryDelay
tofalse
to disable the default behavior of sending retry, or set parameterretryDelay
tomilliseconds
override the default 3000 retry interval .