next.js
v1.0.3
Published
a tiny library for callback style async programing
Downloads
3,021
Readme
next
next 是一个为callback风格的异步编程提供支持的工具库。 next和Async.js的不同之处在于:async是调用函数, next是生成函数
优势
函数复用-- 针对函数而不是针对过程,可以对函数进行组合和连接。采用node风格的callback机制,直接可以复用系统函数。
扁平化callback层次-- 使用next.pipe(fn1, fn2, fnN)连接函数,扁平化callback层次。
统一的异常处理-- 在pipe、map、parallel等方法中进行组合的函数,一旦发生异常,则会统一跳到运行时传入callback进行处理,不用重复判断每级的error。
API
pipe([fn1], [fn2], [fnN])
生成一个函数,先调用fn1,完成之后以fn1的返回值调用fn2,以此类推。 在调用的时候如果有异常,直接跳到运行时传入的callback
var add2 = next.pipe(
function(num, callback) { callback(null, num + 1, num + 2) },
function(num1, num2, callback) { callback(null, num1 + 3, num2 + 3) }
);
add2(1, function() {
console.log(arguments);
});
// result: [null, 5, 6]
map(fn)
生成一个函数,遍历入参每一个元素,调用fn。收集完结果之后按照传入顺序返回。
var addEach = next.map(
function(num, callback) { callback(null, num + 1) }
);
addEach([1,2,3], function() {
console.log(arguments);
});
// result: [null, [2,3,4]]
parallel(fn1, [fn2], [fnN])
生成一个函数,以当前参数调用每个fn,收集结果之后返回
var parallelAction = next.parallel(
function(num, callback) { callback(null, num + 1) },
function(num, callback) { callback(null, num + 2) }
);
parallelAction(1, function() {
console.log(arguments);
});
// result: [null, 2,3]
concurrency(fn, limit, [onDrain])
生成一个函数,使得同时运行的fn不超过limit个,超过的调用将被缓存,当有fn执行完毕之后再执行。当所有的fn调用完毕时触发onDrain
var throttledRunner = next.concurrency(function(a, callback) {
console.log('start:' + a);
setTimeout(function() {
console.log('end:' + a);
callback(a);
}, Math.random() * 3000);
}, 5, function() {
console.log('drain');
});
for (var i = 0; i < 1000; i++) {
throttledRunner(i, function() {});
}
rescue(fn, rescuer)
rescuer == (err, callback) -> 生成一个函数,当发生异常时,由rescuer捕获,而不是跳转到运行时的callback。 rescuer接受error和callback作为参数,可以选择返回到正常的分支,或者继续抛出异常。
next.rescue(function(a, callback) {
console.log('raise exception:' + a);
callback(a);
}, function(err, callback) {
console.log('rescue exception');
callback(null, err + ' is rescued')
})('error', function() {
console.log(arguments)
})
// result:
//rescue
//raise exception:error
//rescue exception
echo()
辅助函数,直接返回参数
next.echo([1,2,3], function() {
console.log(arguments);
});
// result: [null, [1,2,3]]
在parallel的时候,使用echo可以返回原参数
var parallelAction = next.parallel(
next.echo,
function(num1, num2, callback) { callback(null, num1 + 1, num2 + 1) },
function(num1, num2, callback) { callback(null, num1 + 2, num2 + 2) }
);
parallelAction(1, 1, function() {
console.log(arguments);
});
// result: [null, 1, 1, 2, 3, 3]
一些功能示例
compress
从页面上读取script标签src -> 获取js文件内容 -> 调用uglify-js压缩 -> 写文件