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
|
var async = require('./support/async');
var expect = require('chai').expect;
describe('compose', function(){
context('all functions succeed', function(){
it('yields the result of the composition of the functions', function(done){
var add2 = function (n, cb) {
setTimeout(function () {
cb(null, n + 2);
});
};
var mul3 = function (n, cb) {
setTimeout(function () {
cb(null, n * 3);
});
};
var add1 = function (n, cb) {
setTimeout(function () {
cb(null, n + 1);
});
};
var add2mul3add1 = async.compose(add1, mul3, add2);
add2mul3add1(3, function (err, result) {
expect(err).to.not.exist;
expect(result).to.eql(16);
done();
});
});
});
context('a function errors', function(){
it('yields the error and does not call later functions', function(done){
var add1called = false;
var mul3error = new Error('mul3 error');
var add2 = function (n, cb) {
setTimeout(function () {
cb(null, n + 2);
});
};
var mul3 = function (n, cb) {
setTimeout(function () {
cb(mul3error);
});
};
var add1 = function (n, cb) {
add1called = true;
setTimeout(function () {
cb(null, n + 1);
});
};
var add2mul3add1 = async.compose(add1, mul3, add2);
add2mul3add1(3, function (err, result) {
expect(err).to.eql(mul3error);
expect(result).to.not.exist;
expect(add1called).to.be.false;
done();
});
});
});
it('calls each function with the binding of the composed function', function(done){
var context = {};
var add2Context = null;
var mul3Context = null;
var add2 = function (n, cb) {
add2Context = this;
setTimeout(function () {
cb(null, n + 2);
});
};
var mul3 = function (n, cb) {
mul3Context = this;
setTimeout(function () {
cb(null, n * 3);
});
};
var add2mul3 = async.compose(mul3, add2);
add2mul3.call(context, 3, function (err, result) {
expect(err).to.not.exist;
expect(result).to.eql(15);
expect(add2Context).to.equal(context);
expect(mul3Context).to.equal(context);
done();
});
});
});
|
