SSE handler

handlers_index.js

function sseHandler(res) {
  const mySubscription = ChannelFactNews();
  res.writeHead(200, {
    "Content-Type": "text/event-stream",
  });

  const timer = setInterval(() => {
    const nextValue = mySubscription.next();
    res.write(
      `data: {"done":${nextValue.done}, "value": "${nextValue.value}"}\n\n`
    );
    if (nextValue.done) {
      clearInterval(timer);
    }
  }, 1000);
}