a tiny library for callback style async programing
npm install next.jsnext 是一个为callback风格的异步编程提供支持的工具库。
next和Async.js的不同之处在于:async是调用函数, next是生成函数
* 扁平化callback层次--
使用next.pipe(fn1, fn2, fnN)连接函数,扁平化callback层次。
* 统一的异常处理--
在pipe、map、parallel等方法中进行组合的函数,一旦发生异常,则会统一跳到运行时传入callback进行处理,不用重复判断每级的error。
``javascript
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]
`
javascript
var addEach = next.map(
function(num, callback) { callback(null, num + 1) }
);addEach([1,2,3], function() {
console.log(arguments);
});
// result: [null, [2,3,4]]
`$3
生成一个函数,以当前参数调用每个fn,收集结果之后返回
`javascript
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]
`$3
生成一个函数,使得同时运行的fn不超过limit个,超过的调用将被缓存,当有fn执行完毕之后再执行。当所有的fn调用完毕时触发onDrain
`javascript
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() {});
}
`$3
rescuer == (err, callback) ->
生成一个函数,当发生异常时,由rescuer捕获,而不是跳转到运行时的callback。
rescuer接受error和callback作为参数,可以选择返回到正常的分支,或者继续抛出异常。
`javascript
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
`
$3
辅助函数,直接返回参数
`javascript
next.echo([1,2,3], function() {
console.log(arguments);
});
// result: [null, [1,2,3]]`在parallel的时候,使用echo可以返回原参数
`javascript
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]
``