passthrough - stream javascript

Cómo eliminar correctamente los escuchas de eventos en el nodo js eventemitter

Question

Tengo una configuración con una ruta GET y POST, la idea es que POSTing a la ruta desencadena un evento, y la ruta GET es un flujo de eventos enviado por el servidor que se activa cada vez que se desencadena el evento POST ... sin embargo, i creo que he hecho algo mal, ya que los oyentes de eventos parecen ser agregados de manera rutinaria a pesar de tener solo un suscriptor de flujo de eventos ... ¿qué estoy haciendo mal?

var events = require(''events''),
EventEmitter = events.EventEmitter,
rr = new EventEmitter();

app.post(''/api/:boardname/remoterefresh'', function(req, res){
    var boardname = req.param(''boardname''),
    data = new Date().getTime();
    rr.emit("refresh-"+boardname, data)
    res.json({data: data})
});

app.get(''/api/:boardname/remoterefresh'', function(req, res){
    var boardname = req.param(''boardname'')

    rr.on("refresh-"+boardname, function(data){
        setTimeout(function(){
            res.write(''data: ''+data+''/n/n'');
        }, 1000)
    });

    req.socket.setTimeout(Infinity);

    res.writeHead(200, {
        ''Content-Type'': ''text/event-stream'',
        ''Cache-Control'': ''no-cache'',
        ''Connection'': ''keep-alive''
    });

    res.write(''/n'');

    req.on(''close'', function(){
        console.log(''closed'')
        rr.removeListener("refresh-"+boardname, function(){
            //
        })
    })

})

Answer 1

Debe nombrar la función que adjunta como controlador de eventos. Luego, al eliminarlo, simplemente pasa la función por su nombre:

app.get(''/api/:boardname/remoterefresh'', function(req, res){
    var boardname = req.param(''boardname'')
    function refreshHandler(data){
        setTimeout(function(){
            res.write(''data: ''+data+''/n/n'');
        }, 1000)
    }
    rr.on("refresh-"+boardname, refreshHandler);

    req.socket.setTimeout(Infinity);

    res.writeHead(200, {
        ''Content-Type'': ''text/event-stream'',
        ''Cache-Control'': ''no-cache'',
        ''Connection'': ''keep-alive''
    });

    res.write(''/n'');

    req.on(''close'', function(){
        console.log(''closed'')
        rr.removeListener("refresh-"+boardname, refreshHandler);
    });
});

Básicamente, removeListener buscará la función dada por referencia, si encuentra esa función, la eliminará del controlador de eventos.