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
|
var async = require('../lib');
var expect = require('chai').expect;
describe('mapValues', function () {
var obj = {a: 1, b: 2, c: 3};
context('mapValuesLimit', function () {
it('basics', function (done) {
var running = 0;
var concurrency = {
a: 2,
b: 2,
c: 1
};
async.mapValuesLimit(obj, 2, function (val, key, next) {
running++;
async.setImmediate(function () {
expect(running).to.equal(concurrency[key]);
running--;
next(null, key + val);
});
}, function (err, result) {
expect(running).to.equal(0);
expect(err).to.eql(null);
expect(result).to.eql({a: 'a1', b: 'b2', c: 'c3'});
done();
});
});
it('error', function (done) {
async.mapValuesLimit(obj, 1, function(val, key, next) {
if (key === 'b') {
return next(new Error("fail"));
}
next(null, val);
}, function (err, result) {
expect(err).to.not.eql(null);
expect(result).to.eql({a: 1});
done();
});
});
});
context('mapValues', function () {
it('basics', function (done) {
var running = 0;
var concurrency = {
a: 3,
b: 2,
c: 1
};
async.mapValues(obj, function (val, key, next) {
running++;
async.setImmediate(function () {
expect(running).to.equal(concurrency[key]);
running--;
next(null, key + val);
});
}, function (err, result) {
expect(running).to.equal(0);
expect(err).to.eql(null);
expect(result).to.eql({a: 'a1', b: 'b2', c: 'c3'});
done();
});
});
});
context('mapValuesSeries', function () {
it('basics', function (done) {
var running = 0;
var concurrency = {
a: 1,
b: 1,
c: 1
};
async.mapValuesSeries(obj, function (val, key, next) {
running++;
async.setImmediate(function () {
expect(running).to.equal(concurrency[key]);
running--;
next(null, key + val);
});
}, function (err, result) {
expect(running).to.equal(0);
expect(err).to.eql(null);
expect(result).to.eql({a: 'a1', b: 'b2', c: 'c3'});
done();
});
});
});
});
|
