Press n or j to go to the next uncovered block, b, p or k for the previous block.
| 1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 | 77x 77x 3x 1x 1x 1x 1x 1x 1x 1x | import asyncRouteHandler from "../../utilities/asyncRouteHandler.js";
import eventEmiter from "../../utilities/eventEmiter.js";
const feedbacksReceivers = []
eventEmiter.on("feedback", (feedback) => {
feedbacksReceivers.forEach((receiver) => {
receiver(feedback)
})
})
export default asyncRouteHandler(
async function feedbacks_SSE_get(_req, res) {
res.writeHead(200, {
'Content-Type': 'text/event-stream',
'Cache-Control': 'no-cache',
'Connection': 'keep-alive'
});
const receiverIndex = feedbacksReceivers.length;
feedbacksReceivers.push((feedback) => {
res.write(`data: ${JSON.stringify(feedback)}\n\n`)
})
res.on("close", () => {
delete feedbacksReceivers[receiverIndex]
})
}
) |