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
|
var async = require('../lib');
var expect = require('chai').expect;
var assert = require('assert');
describe('seq', function() {
it('seq', function(done) {
var add2 = function (n, cb) {
expect(n).to.equal(3);
setTimeout(function () {
cb(null, n + 2);
}, 50);
};
var mul3 = function (n, cb) {
expect(n).to.equal(5);
setTimeout(function () {
cb(null, n * 3);
}, 15);
};
var add1 = function (n, cb) {
expect(n).to.equal(15);
setTimeout(function () {
cb(null, n + 1);
}, 100);
};
var add2mul3add1 = async.seq(add2, mul3, add1);
add2mul3add1(3, function (err, result) {
if (err) {
return done(err);
}
assert(err === null, err + " passed instead of 'null'");
expect(result).to.equal(16);
done();
});
});
it('seq error', function(done) {
var testerr = new Error('test');
var add2 = function (n, cb) {
expect(n).to.equal(3);
setTimeout(function () {
cb(null, n + 2);
}, 50);
};
var mul3 = function (n, cb) {
expect(n).to.equal(5);
setTimeout(function () {
cb(testerr);
}, 15);
};
var add1 = function (n, cb) {
assert(false, 'add1 should not get called');
setTimeout(function () {
cb(null, n + 1);
}, 100);
};
var add2mul3add1 = async.seq(add2, mul3, add1);
add2mul3add1(3, function (err) {
expect(err).to.equal(testerr);
done();
});
});
it('seq binding', function(done) {
var testcontext = {name: 'foo'};
var add2 = function (n, cb) {
expect(this).to.equal(testcontext);
setTimeout(function () {
cb(null, n + 2);
}, 50);
};
var mul3 = function (n, cb) {
expect(this).to.equal(testcontext);
setTimeout(function () {
cb(null, n * 3);
}, 15);
};
var add2mul3 = async.seq(add2, mul3);
add2mul3.call(testcontext, 3, function (err, result) {
if (err) {
return done(err);
}
expect(this).to.equal(testcontext);
expect(result).to.equal(15);
done();
});
});
it('seq without callback', function(done) {
var testcontext = {name: 'foo'};
var add2 = function (n, cb) {
expect(this).to.equal(testcontext);
setTimeout(function () {
cb(null, n + 2);
}, 50);
};
var mul3 = function () {
expect(this).to.equal(testcontext);
setTimeout(function () {
done();
}, 15);
};
var add2mul3 = async.seq(add2, mul3);
add2mul3.call(testcontext, 3);
});
});
|
