16

eventemitter尽管欢迎其他事件库建议，但我正在使用节点。

如果触发了多个事件，我想运行一次函数。应该监听多个事件，但如果任何一个事件触发，它们都会被删除。希望此代码示例演示了我正在寻找的内容。

var game = new eventEmitter();
game.once(['player:quit', 'player:disconnect'], function () {
  endGame()
});

处理这个最干净的方法是什么？

注意：需要单独移除绑定的函数，因为还会绑定其他监听器。

4

7 回答 7

10

像这样“扩展” EventEmitter：

var EventEmitter = require('events').EventEmitter;

EventEmitter.prototype.once = function(events, handler){
    // no events, get out!
    if(! events)
        return; 

    // Ugly, but helps getting the rest of the function 
    // short and simple to the eye ... I guess...
    if(!(events instanceof Array))
        events = [events];

    var _this = this;

    var cb = function(){
        events.forEach(function(e){     
            // This only removes the listener itself 
            // from all the events that are listening to it
            // i.e., does not remove other listeners to the same event!
            _this.removeListener(e, cb); 
        });

        // This will allow any args you put in xxx.emit('event', ...) to be sent 
        // to your handler
        handler.apply(_this, Array.prototype.slice.call(arguments, 0));
    };

    events.forEach(function(e){ 
        _this.addListener(e, cb);
    }); 
};

我在这里创建了一个要点：https ://gist.github.com/3627823 其中包括一个示例（您的示例，带有一些日志）

[更新]以下是我的实现的改编，once它只删除了被调用的事件，如评论中所要求的：

var EventEmitter = require('events').EventEmitter;

EventEmitter.prototype.once = function(events, handler){
    // no events, get out!
    if(! events)
        return; 

    // Ugly, but helps getting the rest of the function 
    // short and simple to the eye ... I guess...
    if(!(events instanceof Array))
        events = [events];

    var _this = this;

    // A helper function that will generate a handler that 
    // removes itself when its called
    var gen_cb = function(event_name){
        var cb = function(){
            _this.removeListener(event_name, cb);
            // This will allow any args you put in 
            // xxx.emit('event', ...) to be sent 
            // to your handler
            handler.apply(_this, Array.prototype.slice.call(arguments, 0));
        };
        return cb;
    };


    events.forEach(function(e){ 
        _this.addListener(e, gen_cb(e));
    }); 
};

我发现 node.js 已经once在 EventEmitter 中有一个方法：查看这里的源代码，但这可能是最近添加的。

于 2012-09-04T23:16:28.997 回答
4

像这样的东西怎么样：

var game = new EventEmitter();

var handler = function() {
  game.removeAllListeners('player:quit');
  game.removeAllListeners('player:disconnect');
  endGame();
};

game.on('player:quit', handler);
game.on('player:disconnect', handler);

您可以编写一个包装器on并removeAllListeners能够传入一个数组（例如，循环数组并为每个元素调用on或）。removeAllListeners

于 2012-08-27T23:15:00.780 回答
1

使用 的first运算符Rx.Observable：

let game = new EventEmitter();
let events = ['player:quit', 'player:disconnect'];

//let myObserver = Rx.Observable.fromEventPattern(handler => {
//  events.forEach(evt => game.on(evt, handler));
//}).first();

let myObserver = Rx.Observable.merge(...events.map(evt => Rx.Observable.fromEvent(game, evt))).first();

myObserver.subscribe(() => {
  // clean up
  console.log('Goodbye!!');
});

game.emit('player:quit'); // Goodbye!!
game.emit('player:quit'); // No output
game.emit('player:disconnect'); // No output
<script src="https://cdnjs.cloudflare.com/ajax/libs/rxjs/5.4.0/Rx.min.js"></script>
<script src="https://cdnjs.cloudflare.com/ajax/libs/EventEmitter/5.1.0/EventEmitter.min.js"></script>

于 2017-06-13T21:35:16.113 回答
0

不幸的是，您还没有任何类似的东西。

我查看EventEmitter2但我认为有一个问题......（#66，#31）

于 2012-09-03T19:22:46.917 回答
0

下面的方法怎么样

var myEmitter = new CustomEventEmitter;
myEmitter.onceAny(['event1', 'event2', 'event3', 'event4'], function() {
        endGame();
});

当 CustomEventEmitter 看起来像这样时

function CustomEventEmitter() {};

// inherit from EventEmitter
CustomEventEmitter.prototype = new EventEmitter;

CustomEventEmitter.prototype.onceAny = function(arrayEvents, callback) {
    // generate unique string for the auxiliary event
    var auxEvent = process.pid + '-' + (new Date()).getTime();

    // auxiliary event handler
    var auxEmitter = new EventEmitter;

    // handle the event emitted by the auxiliary emitter
    auxEmitter.once(auxEvent, callback);

    for (var i = 0; i < arrayEvents.length;  i++) {
        this.once(arrayEvents[i], function() {
            auxEmitter.emit(auxEvent);
        });
    }

}

两个事件处理程序的级联会产生所需的结果。您正在使用辅助 EventEmitter，但它的详细信息隐藏在 CustomEventEmitter 模块中，因此该模块的使用非常简单。

于 2012-09-07T09:07:07.770 回答
0

这是处理此工作流程的通用辅助函数。您需要传递对事件发射器对象的引用、事件名称数组和事件处理函数。处理所有附加、分离和传递参数到您的处理程序。

// listen to many, trigger and detach all on any
function onMany(emitter, events, callback) {
    function cb() {
        callback.apply(emitter, arguments);

        events.forEach(function(ev) {
            emitter.removeListener(ev, cb);
        });
    }

    events.forEach(function(ev) {
        emitter.on(ev, cb);
    });
}

还有一个使用示例：

// Test usage
var EventEmitter = require('events').EventEmitter;
var game = new EventEmitter();

// event list of interest
var events = ['player:quit', 'player:disconnect'];

// end game handler
function endGame() {
    console.log('end the game!');
}

// attach
onMany(game, events, endGame);

// test. we should log 'end the game' only once
game.emit('player:disconnect');
game.emit('player:quit');
于 2012-09-07T13:41:13.637 回答
0

我刚遇到类似的事情，尽管在这里分享。可能它对您的情况也有帮助吗？

我有一个看起来像这样的模块：

require('events').EventEmitter;
function Foobar = {};
Foobar.prototype = new EventEmitter();
Foobar.prototype.someMethod = function() { ... }

module.exports.getNewFoobar = function() {
    return new Foobar();
};

有趣的是：这在 node.js 0.8.x 之前一直有效，但不再有效。问题是这一行：

Foobar.prototype = new EventEmitter();

使用这一行，所有创建的实例都共享，并且与 Javascript 中的非标量值相同的 EventEmitter 始终是引用。显然 node.js 改变了一些关于模块的内部行为，因为这在以前是有效的。

解决方案是使用允许正确继承的 util 类。

require('events').EventEmitter;
var util = require('util');

function Foobar = {};
util.inherits(Foobar, EventEmitter);

Foobar.prototype.someMethod = function() { ... }

module.exports.getNewFoobar = function() {
    return new Foobar();
};

希望这可以帮助。

于 2013-12-10T21:50:26.477 回答