You can not select more than 25 topics
Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.
98 lines
2.4 KiB
98 lines
2.4 KiB
/*!
|
|
* ee-first
|
|
* Copyright(c) 2014 Jonathan Ong
|
|
* MIT Licensed
|
|
*/
|
|
|
|
'use strict'; // 使用严格模式
|
|
|
|
/**
|
|
* 模块导出
|
|
* @public
|
|
*/
|
|
module.exports = first;
|
|
|
|
/**
|
|
* 获取一组事件发射器和事件对中的第一个事件。
|
|
*
|
|
* @param {array} stuff - 包含事件发射器和事件的数组
|
|
* @param {function} done - 当事件触发时调用的回调函数
|
|
* @public
|
|
*/
|
|
function first(stuff, done) {
|
|
// 检查 stuff 是否为数组
|
|
if (!Array.isArray(stuff))
|
|
throw new TypeError('arg must be an array of [ee, events...] arrays');
|
|
|
|
var cleanups = []; // 用于存储清理函数的数组
|
|
|
|
// 遍历传入的 stuff 数组
|
|
for (var i = 0; i < stuff.length; i++) {
|
|
var arr = stuff[i];
|
|
|
|
// 检查每个元素是否为数组，且长度至少为 2
|
|
if (!Array.isArray(arr) || arr.length < 2)
|
|
throw new TypeError('each array member must be [ee, events...]');
|
|
|
|
var ee = arr[0]; // 获取事件发射器
|
|
|
|
// 遍历事件数组
|
|
for (var j = 1; j < arr.length; j++) {
|
|
var event = arr[j];
|
|
var fn = listener(event, callback); // 创建事件监听器
|
|
|
|
// 监听事件
|
|
ee.on(event, fn);
|
|
// 将此监听器推入清理列表
|
|
cleanups.push({
|
|
ee: ee,
|
|
event: event,
|
|
fn: fn,
|
|
});
|
|
}
|
|
}
|
|
|
|
// 事件触发时的回调函数
|
|
function callback() {
|
|
cleanup(); // 清理所有监听器
|
|
done.apply(null, arguments); // 调用传入的 done 函数
|
|
}
|
|
|
|
// 清理函数，移除所有监听器
|
|
function cleanup() {
|
|
var x;
|
|
for (var i = 0; i < cleanups.length; i++) {
|
|
x = cleanups[i];
|
|
x.ee.removeListener(x.event, x.fn); // 移除监听器
|
|
}
|
|
}
|
|
|
|
// 返回一个 thunk 函数
|
|
function thunk(fn) {
|
|
done = fn; // 更新 done 函数
|
|
}
|
|
|
|
thunk.cancel = cleanup; // 将清理函数附加到 thunk 上
|
|
|
|
return thunk; // 返回 thunk 函数
|
|
}
|
|
|
|
/**
|
|
* 创建事件监听器。
|
|
* @private
|
|
*/
|
|
function listener(event, done) {
|
|
return function onevent(arg1) {
|
|
var args = new Array(arguments.length); // 创建一个新数组来存储参数
|
|
var ee = this; // 获取事件发射器的上下文
|
|
var err = event === 'error' ? arg1 : null; // 如果是 'error' 事件，设置错误参数
|
|
|
|
// 复制参数以防止 arguments 逃逸作用域
|
|
for (var i = 0; i < args.length; i++) {
|
|
args[i] = arguments[i];
|
|
}
|
|
|
|
done(err, ee, event, args); // 调用 done 函数，传入错误、事件发射器、事件和参数
|
|
};
|
|
}
|