var fs = require('fs');
var EventProxy = require('eventproxy');
var ep = new EventProxy();
// all()方法用于指定接收哪几种事件,并在回调函数中进行统一处理,回调函数可以接收事件中携带的参数,参数位置与事件位置一一对应
ep.all(['read_file1', 'read_file2', 'read_file3'], function (data1, data2, data3) {
console.log(data1 + data2 + data3);
});
fs.readFile('/file1.txt', 'utf8', function (err, data) {
// 使用emit抛出一个事件 read_file1
ep.emit('read_file1', data);
});
fs.readFile('/file2.txt', 'utf8', function (err, data) {
// 使用emit抛出一个事件 read_file2
ep.emit('read_file2', data);
});
fs.readFile('/file3.txt', 'utf8', function (err, data) {
// 使用emit抛出一个事件 read_file3
ep.emit('read_file3', data);
}); |