var urls = 'http://127.0.0.1:8844/stream'
    var sse = new EventSource(urls)
    sse.onopen = function (e) {
      console.log(e.type)
    }
    sse.onerror = function (e) {
      console.log(e)
    }
    sse.onmessage = function (e) {
      console.log(e.data)
    }
    sse.addEventListener ('hello', function (e) {
      // console.log(e.type)
      console.log(e.data)
    })

var http = require("http");

http.createServer(function (req, res) {
  var fileName = "." + req.url;

  if (fileName === "./stream") {
    res.writeHead(200, {
      "Content-Type":"text/event-stream",
      "Cache-Control":"no-cache",
      "Connection":"keep-alive",
      "Access-Control-Allow-Origin": '*',
    });
    res.write("retry: 10000\n");
    
    interval = setInterval(function () {
      res.write("event: hello\n");
      res.write("data: " + Date.now() + "\n\n");
      res.write("event: hello\n");
      res.write("data: " + 111 + "\n\n"); 
    }, 1000);

    req.connection.addListener("close", function () {
      clearInterval(interval);
    }, false);
  }
}).listen(8844, "127.0.0.1");