|
1 | 1 | describe('API', function () { |
2 | 2 | it('should be a constructor', function () { |
3 | | - var Parallel = require('../lib/parallel.js'); |
| 3 | + var Parallel = require('../lib/thread.js'); |
4 | 4 | expect(Parallel).toEqual(jasmine.any(Function)); |
5 | 5 | }); |
6 | 6 |
|
7 | 7 | it('should define a .then(cb) function', function () { |
8 | | - var Parallel = require('../lib/parallel.js'); |
| 8 | + var Parallel = require('../lib/thread.js'); |
9 | 9 | var p = new Parallel([1, 2, 3]); |
10 | 10 | expect(p.then).toEqual(jasmine.any(Function)); |
11 | 11 | }); |
12 | 12 |
|
13 | 13 | it('should define a .map(cb) function', function () { |
14 | | - var Parallel = require('../lib/parallel.js'); |
| 14 | + var Parallel = require('../lib/thread.js'); |
15 | 15 | var p = new Parallel([1, 2, 3]); |
16 | 16 | expect(p.map).toEqual(jasmine.any(Function)); |
17 | 17 | }); |
18 | 18 |
|
19 | 19 | it('should execute a .then function without an operation immediately', function () { |
20 | | - var Parallel = require('../lib/parallel.js'); |
| 20 | + var Parallel = require('../lib/thread.js'); |
21 | 21 | var p = new Parallel([1, 2, 3]); |
22 | 22 | expect(p.then).toEqual(jasmine.any(Function)); |
23 | 23 |
|
|
33 | 33 | }); |
34 | 34 |
|
35 | 35 | it('should execute .spawn() correctly', function () { |
36 | | - var Parallel = require('../lib/parallel.js'); |
| 36 | + var Parallel = require('../lib/thread.js'); |
37 | 37 | var p = new Parallel([1, 2, 3]); |
38 | 38 |
|
39 | 39 | var done = false; |
|
58 | 58 | }); |
59 | 59 |
|
60 | 60 | it('should .map() correctly', function () { |
61 | | - var Parallel = require('../lib/parallel.js'); |
| 61 | + var Parallel = require('../lib/thread.js'); |
62 | 62 | var p = new Parallel([1, 2, 3]); |
63 | 63 |
|
64 | 64 | var done = false; |
|
83 | 83 | }); |
84 | 84 |
|
85 | 85 | it('should queue map work correctly', function () { |
86 | | - var Parallel = require('../lib/parallel.js'); |
| 86 | + var Parallel = require('../lib/thread.js'); |
87 | 87 | var p = new Parallel([1, 2, 3], {maxWorkers: 2}); |
88 | 88 |
|
89 | 89 | var done = false; |
|
108 | 108 | }); |
109 | 109 |
|
110 | 110 | it('should chain .map() correctly', function () { |
111 | | - var Parallel = require('../lib/parallel.js'); |
| 111 | + var Parallel = require('../lib/thread.js'); |
112 | 112 | var p = new Parallel([1, 2, 3]); |
113 | 113 |
|
114 | 114 | var done = false; |
|
135 | 135 | }); |
136 | 136 |
|
137 | 137 | it('should mix .spawn and .map() correctly', function () { |
138 | | - var Parallel = require('../lib/parallel.js'); |
| 138 | + var Parallel = require('../lib/thread.js'); |
139 | 139 | var p = new Parallel([1, 2, 3]); |
140 | 140 |
|
141 | 141 | var done = false; |
|
166 | 166 | }); |
167 | 167 |
|
168 | 168 | it('should execute .reduce() correctly', function () { |
169 | | - var Parallel = require('../lib/parallel.js'); |
| 169 | + var Parallel = require('../lib/thread.js'); |
170 | 170 | var p = new Parallel([1, 2, 3]); |
171 | 171 | var done = false; |
172 | 172 | var result = null; |
|
190 | 190 | }); |
191 | 191 |
|
192 | 192 | it('should process data returned from .then()', function () { |
193 | | - var Parallel = require('../lib/parallel.js'); |
| 193 | + var Parallel = require('../lib/thread.js'); |
194 | 194 | var p = new Parallel([1, 2, 3]); |
195 | 195 |
|
196 | 196 | var done = false; |
|
0 commit comments