diff options
-rw-r--r-- | mocha_test/parallel.js | 277 | ||||
-rw-r--r-- | mocha_test/support/get_function_object.js | 22 | ||||
-rwxr-xr-x | test/test-async.js | 271 |
3 files changed, 299 insertions, 271 deletions
diff --git a/mocha_test/parallel.js b/mocha_test/parallel.js new file mode 100644 index 0000000..5362491 --- /dev/null +++ b/mocha_test/parallel.js @@ -0,0 +1,277 @@ +var async = require('../lib'); +var expect = require('chai').expect; +var assert = require('assert'); +var isBrowser = require('./support/is_browser'); +var getFunctionsObject = require('./support/get_function_object'); + +describe('parallel', function() { + + it('parallel', function(done) { + var call_order = []; + async.parallel([ + function(callback){ + setTimeout(function(){ + call_order.push(1); + callback(null, 1); + }, 50); + }, + function(callback){ + setTimeout(function(){ + call_order.push(2); + callback(null, 2); + }, 100); + }, + function(callback){ + setTimeout(function(){ + call_order.push(3); + callback(null, 3,3); + }, 25); + } + ], + function(err, results){ + assert(err === null, err + " passed instead of 'null'"); + expect(call_order).to.eql([3,1,2]); + expect(results).to.eql([1,2,[3,3]]); + done(); + }); + }); + + it('parallel empty array', function(done) { + async.parallel([], function(err, results){ + assert(err === null, err + " passed instead of 'null'"); + expect(results).to.eql([]); + done(); + }); + }); + + it('parallel error', function(done) { + async.parallel([ + function(callback){ + callback('error', 1); + }, + function(callback){ + callback('error2', 2); + } + ], + function(err){ + expect(err).to.equal('error'); + }); + setTimeout(done, 100); + }); + + it('parallel no callback', function(done) { + async.parallel([ + function(callback){callback();}, + function(callback){callback(); done();}, + ]); + }); + + it('parallel object', function(done) { + var call_order = []; + async.parallel(getFunctionsObject(call_order), function(err, results){ + expect(err).to.equal(null); + expect(call_order).to.eql([3,1,2]); + expect(results).to.eql({ + one: 1, + two: 2, + three: [3,3] + }); + done(); + }); + }); + + // Issue 10 on github: https://github.com/caolan/async/issues#issue/10 + it('paralel falsy return values', function(done) { + function taskFalse(callback) { + async.nextTick(function() { + callback(null, false); + }); + } + function taskUndefined(callback) { + async.nextTick(function() { + callback(null, undefined); + }); + } + function taskEmpty(callback) { + async.nextTick(function() { + callback(null); + }); + } + function taskNull(callback) { + async.nextTick(function() { + callback(null, null); + }); + } + async.parallel( + [taskFalse, taskUndefined, taskEmpty, taskNull], + function(err, results) { + expect(results.length).to.equal(4); + assert.strictEqual(results[0], false); + assert.strictEqual(results[1], undefined); + assert.strictEqual(results[2], undefined); + assert.strictEqual(results[3], null); + done(); + } + ); + }); + + + it('parallel limit', function(done) { + var call_order = []; + async.parallelLimit([ + function(callback){ + setTimeout(function(){ + call_order.push(1); + callback(null, 1); + }, 50); + }, + function(callback){ + setTimeout(function(){ + call_order.push(2); + callback(null, 2); + }, 100); + }, + function(callback){ + setTimeout(function(){ + call_order.push(3); + callback(null, 3,3); + }, 25); + } + ], + 2, + function(err, results){ + assert(err === null, err + " passed instead of 'null'"); + expect(call_order).to.eql([1,3,2]); + expect(results).to.eql([1,2,[3,3]]); + done(); + }); + }); + + it('parallel limit empty array', function(done) { + async.parallelLimit([], 2, function(err, results){ + assert(err === null, err + " passed instead of 'null'"); + expect(results).to.eql([]); + done(); + }); + }); + + it('parallel limit error', function(done) { + async.parallelLimit([ + function(callback){ + callback('error', 1); + }, + function(callback){ + callback('error2', 2); + } + ], + 1, + function(err){ + expect(err).to.equal('error'); + }); + setTimeout(done, 100); + }); + + it('parallel limit no callback', function(done) { + async.parallelLimit([ + function(callback){callback();}, + function(callback){callback(); done();}, + ], 1); + }); + + it('parallel limit object', function(done) { + var call_order = []; + async.parallelLimit(getFunctionsObject(call_order), 2, function(err, results){ + expect(err).to.equal(null); + expect(call_order).to.eql([1,3,2]); + expect(results).to.eql({ + one: 1, + two: 2, + three: [3,3] + }); + done(); + }); + }); + + it('parallel call in another context', function(done) { + if (isBrowser()) { + // node only test + done(); + return; + } + var vm = require('vm'); + var sandbox = { + async: async, + done: done + }; + + var fn = "(" + (function () { + async.parallel([function (callback) { + callback(); + }], function (err) { + if (err) { + return done(err); + } + done(); + }); + }).toString() + "())"; + + vm.runInNewContext(fn, sandbox); + }); + + it('parallel error with reflect', function(done) { + async.parallel([ + async.reflect(function(callback){ + callback('error', 1); + }), + async.reflect(function(callback){ + callback('error2', 2); + }), + async.reflect(function(callback){ + callback(null, 2); + }) + ], + function(err, results){ + assert(err === null, err + " passed instead of 'null'"); + expect(results).to.eql([ + { error: 'error' }, + { error: 'error2' }, + { value: 2 } + ]); + done(); + }); + }); + + it('parallel does not continue replenishing after error', function(done) { + var started = 0; + var arr = [ + funcToCall, + funcToCall, + funcToCall, + funcToCall, + funcToCall, + funcToCall, + funcToCall, + funcToCall, + funcToCall, + ]; + var delay = 10; + var limit = 3; + var maxTime = 10 * arr.length; + function funcToCall(callback) { + started ++; + if (started === 3) { + return callback(new Error ("Test Error")); + } + setTimeout(function(){ + callback(); + }, delay); + } + + async.parallelLimit(arr, limit, function(){}); + + setTimeout(function(){ + expect(started).to.equal(3); + done(); + }, maxTime); + }); +}); diff --git a/mocha_test/support/get_function_object.js b/mocha_test/support/get_function_object.js new file mode 100644 index 0000000..008fd8f --- /dev/null +++ b/mocha_test/support/get_function_object.js @@ -0,0 +1,22 @@ +module.exports = function (call_order) { + return { + one: function(callback) { + setTimeout(function() { + call_order.push(1); + callback(null, 1); + }, 125); + }, + two: function(callback) { + setTimeout(function() { + call_order.push(2); + callback(null, 2); + }, 200); + }, + three: function(callback) { + setTimeout(function() { + call_order.push(3); + callback(null, 3, 3); + }, 50); + } + }; +}; diff --git a/test/test-async.js b/test/test-async.js index e35bdcf..e02c0df 100755 --- a/test/test-async.js +++ b/test/test-async.js @@ -152,277 +152,6 @@ exports['seq without callback'] = function (test) { add2mul3.call(testcontext, 3); }; - -exports['parallel'] = function(test){ - var call_order = []; - async.parallel([ - function(callback){ - setTimeout(function(){ - call_order.push(1); - callback(null, 1); - }, 50); - }, - function(callback){ - setTimeout(function(){ - call_order.push(2); - callback(null, 2); - }, 100); - }, - function(callback){ - setTimeout(function(){ - call_order.push(3); - callback(null, 3,3); - }, 25); - } - ], - function(err, results){ - test.ok(err === null, err + " passed instead of 'null'"); - test.same(call_order, [3,1,2]); - test.same(results, [1,2,[3,3]]); - test.done(); - }); -}; - -exports['parallel empty array'] = function(test){ - async.parallel([], function(err, results){ - test.ok(err === null, err + " passed instead of 'null'"); - test.same(results, []); - test.done(); - }); -}; - -exports['parallel error'] = function(test){ - async.parallel([ - function(callback){ - callback('error', 1); - }, - function(callback){ - callback('error2', 2); - } - ], - function(err){ - test.equals(err, 'error'); - }); - setTimeout(test.done, 100); -}; - -exports['parallel no callback'] = function(test){ - async.parallel([ - function(callback){callback();}, - function(callback){callback(); test.done();}, - ]); -}; - -exports['parallel object'] = function(test){ - var call_order = []; - async.parallel(getFunctionsObject(call_order), function(err, results){ - test.equals(err, null); - test.same(call_order, [3,1,2]); - test.same(results, { - one: 1, - two: 2, - three: [3,3] - }); - test.done(); - }); -}; - -// Issue 10 on github: https://github.com/caolan/async/issues#issue/10 -exports['paralel falsy return values'] = function (test) { - function taskFalse(callback) { - async.nextTick(function() { - callback(null, false); - }); - } - function taskUndefined(callback) { - async.nextTick(function() { - callback(null, undefined); - }); - } - function taskEmpty(callback) { - async.nextTick(function() { - callback(null); - }); - } - function taskNull(callback) { - async.nextTick(function() { - callback(null, null); - }); - } - async.parallel( - [taskFalse, taskUndefined, taskEmpty, taskNull], - function(err, results) { - test.equal(results.length, 4); - test.strictEqual(results[0], false); - test.strictEqual(results[1], undefined); - test.strictEqual(results[2], undefined); - test.strictEqual(results[3], null); - test.done(); - } - ); -}; - - -exports['parallel limit'] = function(test){ - var call_order = []; - async.parallelLimit([ - function(callback){ - setTimeout(function(){ - call_order.push(1); - callback(null, 1); - }, 50); - }, - function(callback){ - setTimeout(function(){ - call_order.push(2); - callback(null, 2); - }, 100); - }, - function(callback){ - setTimeout(function(){ - call_order.push(3); - callback(null, 3,3); - }, 25); - } - ], - 2, - function(err, results){ - test.ok(err === null, err + " passed instead of 'null'"); - test.same(call_order, [1,3,2]); - test.same(results, [1,2,[3,3]]); - test.done(); - }); -}; - -exports['parallel limit empty array'] = function(test){ - async.parallelLimit([], 2, function(err, results){ - test.ok(err === null, err + " passed instead of 'null'"); - test.same(results, []); - test.done(); - }); -}; - -exports['parallel limit error'] = function(test){ - async.parallelLimit([ - function(callback){ - callback('error', 1); - }, - function(callback){ - callback('error2', 2); - } - ], - 1, - function(err){ - test.equals(err, 'error'); - }); - setTimeout(test.done, 100); -}; - -exports['parallel limit no callback'] = function(test){ - async.parallelLimit([ - function(callback){callback();}, - function(callback){callback(); test.done();}, - ], 1); -}; - -exports['parallel limit object'] = function(test){ - var call_order = []; - async.parallelLimit(getFunctionsObject(call_order), 2, function(err, results){ - test.equals(err, null); - test.same(call_order, [1,3,2]); - test.same(results, { - one: 1, - two: 2, - three: [3,3] - }); - test.done(); - }); -}; - -exports['parallel call in another context'] = function(test) { - if (isBrowser()) { - // node only test - test.done(); - return; - } - var vm = require('vm'); - var sandbox = { - async: async, - test: test - }; - - var fn = "(" + (function () { - async.parallel([function (callback) { - callback(); - }], function (err) { - if (err) { - return test.done(err); - } - test.done(); - }); - }).toString() + "())"; - - vm.runInNewContext(fn, sandbox); -}; - -exports['parallel error with reflect'] = function(test){ - async.parallel([ - async.reflect(function(callback){ - callback('error', 1); - }), - async.reflect(function(callback){ - callback('error2', 2); - }), - async.reflect(function(callback){ - callback(null, 2); - }) - ], - function(err, results){ - test.ok(err === null, err + " passed instead of 'null'"); - test.same(results, [ - { error: 'error' }, - { error: 'error2' }, - { value: 2 } - ]); - test.done(); - }); -}; - -exports['parallel does not continue replenishing after error'] = function (test) { - var started = 0; - var arr = [ - funcToCall, - funcToCall, - funcToCall, - funcToCall, - funcToCall, - funcToCall, - funcToCall, - funcToCall, - funcToCall, - ]; - var delay = 10; - var limit = 3; - var maxTime = 10 * arr.length; - function funcToCall(callback) { - started ++; - if (started === 3) { - return callback(new Error ("Test Error")); - } - setTimeout(function(){ - callback(); - }, delay); - } - - async.parallelLimit(arr, limit, function(){}); - - setTimeout(function(){ - test.equal(started, 3); - test.done(); - }, maxTime); -}; - - exports['series'] = { 'series': function(test){ |