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
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
|
var events = require('events')
var util = require('util')
var Q = require('q')
var helper = require('./helper')
var bindAllEvents = function (object, context) {
context = context || this
var bindMethod = function (method) {
context.on(helper.camelToSnake(method.substr(2)), function () {
var args = Array.prototype.slice.call(arguments, 0)
args.push(context)
object[method].apply(object, args)
})
}
for (var method in object) {
if (helper.isFunction(object[method]) && method.substr(0, 2) === 'on') {
bindMethod(method)
}
}
}
var bufferEvents = function (emitter, eventsToBuffer) {
var listeners = []
var eventsToReply = []
var genericListener = function () {
eventsToReply.push(Array.prototype.slice.call(arguments))
}
eventsToBuffer.forEach(function (eventName) {
var listener = genericListener.bind(null, eventName)
listeners.push(listener)
emitter.on(eventName, listener)
})
return function () {
if (!eventsToReply) {
return
}
// remove all buffering listeners
listeners.forEach(function (listener, i) {
emitter.removeListener(eventsToBuffer[i], listener)
})
// reply
eventsToReply.forEach(function (args) {
events.EventEmitter.prototype.emit.apply(emitter, args)
})
// free-up
listeners = eventsToReply = null
}
}
// TODO(vojta): log.debug all events
var EventEmitter = function () {
this.bind = bindAllEvents
this.emitAsync = function (name) {
// TODO(vojta): allow passing args
// TODO(vojta): ignore/throw if listener call done() multiple times
var pending = this.listeners(name).length
var deferred = Q.defer()
var done = function () {
if (!--pending) {
deferred.resolve()
}
}
this.emit(name, done)
if (!pending) {
deferred.resolve()
}
return deferred.promise
}
}
util.inherits(EventEmitter, events.EventEmitter)
// PUBLISH
exports.EventEmitter = EventEmitter
exports.bindAll = bindAllEvents
exports.bufferEvents = bufferEvents
|
