Spaces:
Runtime error
Runtime error
| /* eslint no-console: "off" */ | |
| var asynckit = require('./') | |
| , async = require('async') | |
| , assert = require('assert') | |
| , expected = 0 | |
| ; | |
| var Benchmark = require('benchmark'); | |
| var suite = new Benchmark.Suite; | |
| var source = []; | |
| for (var z = 1; z < 100; z++) | |
| { | |
| source.push(z); | |
| expected += z; | |
| } | |
| suite | |
| // add tests | |
| .add('async.map', function(deferred) | |
| { | |
| var total = 0; | |
| async.map(source, | |
| function(i, cb) | |
| { | |
| setImmediate(function() | |
| { | |
| total += i; | |
| cb(null, total); | |
| }); | |
| }, | |
| function(err, result) | |
| { | |
| assert.ifError(err); | |
| assert.equal(result[result.length - 1], expected); | |
| deferred.resolve(); | |
| }); | |
| }, {'defer': true}) | |
| .add('asynckit.parallel', function(deferred) | |
| { | |
| var total = 0; | |
| asynckit.parallel(source, | |
| function(i, cb) | |
| { | |
| setImmediate(function() | |
| { | |
| total += i; | |
| cb(null, total); | |
| }); | |
| }, | |
| function(err, result) | |
| { | |
| assert.ifError(err); | |
| assert.equal(result[result.length - 1], expected); | |
| deferred.resolve(); | |
| }); | |
| }, {'defer': true}) | |
| // add listeners | |
| .on('cycle', function(ev) | |
| { | |
| console.log(String(ev.target)); | |
| }) | |
| .on('complete', function() | |
| { | |
| console.log('Fastest is ' + this.filter('fastest').map('name')); | |
| }) | |
| // run async | |
| .run({ 'async': true }); | |