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
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
|
var async = require('../lib');
var expect = require('chai').expect;
var _ = require('lodash');
describe("every", function () {
it('everyLimit true', function(done){
async.everyLimit([3,1,2], 1, function(x, callback){
setTimeout(function(){callback(null, x >= 1);}, 0);
}, function(err, result){
expect(err).to.equal(null);
expect(result).to.equal(true);
done();
});
});
it('everyLimit false', function(done){
async.everyLimit([3,1,2], 2, function(x, callback){
setTimeout(function(){callback(null, x === 2);}, 0);
}, function(err, result){
expect(err).to.equal(null);
expect(result).to.equal(false);
done();
});
});
it('everyLimit short-circuit', function(done){
var calls = 0;
async.everyLimit([3,1,2], 1, function(x, callback){
calls++;
callback(null, x === 1);
}, function(err, result){
expect(err).to.equal(null);
expect(result).to.equal(false);
expect(calls).to.equal(1);
done();
});
});
it('true', function(done){
async.every([1,2,3], function(x, callback){
setTimeout(function(){callback(null, true);}, 0);
}, function(err, result){
expect(err).to.equal(null);
expect(result).to.equal(true);
done();
});
});
it('false', function(done){
async.every([1,2,3], function(x, callback){
setTimeout(function(){callback(null, x % 2);}, 0);
}, function(err, result){
expect(err).to.equal(null);
expect(result).to.equal(false);
done();
});
});
it('early return', function(done){
var call_order = [];
async.every([1,2,3], function(x, callback){
setTimeout(function(){
call_order.push(x);
callback(null, x === 1);
}, x*5);
}, function(){
call_order.push('callback');
});
setTimeout(function(){
expect(call_order).to.eql([1,2,'callback',3]);
done();
}, 25);
});
it('error', function(done){
async.every([1,2,3], function(x, callback){
setTimeout(function(){callback('error');}, 0);
}, function(err, result){
expect(err).to.equal('error');
expect(result).to.not.exist;
done();
});
});
it('everySeries doesn\'t cause stack overflow (#1293)', function(done) {
var arr = _.range(10000);
let calls = 0;
async.everySeries(arr, function(data, cb) {
calls += 1;
async.setImmediate(_.partial(cb, null, false));
}, function(err) {
expect(err).to.equal(null);
expect(calls).to.equal(1);
done();
});
});
it('everyLimit doesn\'t cause stack overflow (#1293)', function(done) {
var arr = _.range(10000);
let calls = 0;
async.everyLimit(arr, 100, function(data, cb) {
calls += 1;
async.setImmediate(_.partial(cb, null, false));
}, function(err) {
expect(err).to.equal(null);
expect(calls).to.equal(100);
done();
});
});
it('all alias', function(){
expect(async.all).to.equal(async.every);
});
it('allLimit alias', function(){
expect(async.allLimit).to.equal(async.everyLimit);
});
it('allSeries alias', function(){
expect(async.allSeries).to.be.a('function');
expect(async.allSeries).to.equal(async.everySeries);
});
});
|
