Make benchmarks async

tshemsedinov · tshemsedinov · commit 8dc043a81dd1 · 2017-04-11T00:06:42.000+03:00
diff --git a/JavaScript/4-test.js b/JavaScript/4-test.js
@@ -1,6 +1,8 @@
 'use strict';
 
-module.exports = (chaining) => {
+module.exports = (chaining, done) => {
+  let count = 0;
+  const next = () => (++count === 3 && done ? done() : 0);
 
   chaining
   .for([1, 2, 3, 4])
@@ -9,7 +11,8 @@ module.exports = (chaining) => {
   .reduce((a, b, cb) => cb(null, a + b))
   .fetch((err, result) => {
     if (err) throw err;
-    console.dir(result);
+    if (!done) console.dir(result);
+    next();
   });
 
   chaining
@@ -19,15 +22,19 @@ module.exports = (chaining) => {
   .reduce((a, b, cb) => process.nextTick(cb, null, a + b))
   .fetch((err, result) => {
     if (err) throw err;
-    console.dir(result);
+    if (!done) console.dir(result);
+    next();
   });
 
   chaining
   .for([1, 2, 3, 4])
   .map((item, cb) => cb(new Error('Something happened')))
   .fetch((err, result) => {
-    if (err) console.log(err.message);
-    else console.dir(result);
+    if (!done) {
+      if (err) console.log(err.message);
+      else console.dir(result);
+    }
+    next();
   });
 
 };
diff --git a/JavaScript/6-benchmark.js b/JavaScript/6-benchmark.js
@@ -8,15 +8,20 @@ const PRE_COUNT = 1000;
 const rpad = (s, char, count) => (s + char.repeat(count - s.length));
 const lpad = (s, char, count) => (char.repeat(count - s.length) + s);
 
-benchmark.do = (count, name, fn) => {
+
+benchmark.do = (num, name, fn) => {
+  const done = () => {
+    const end = process.hrtime(begin);
+    const diff = end[0] * 1e9 + end[1];
+    const time = lpad(diff.toString(), '.', 12);
+    name = rpad(name, '.', 12);
+    console.log(name + time + ' nanoseconds');
+  };
+  let count = 0;
+  const next = () => (++count === num && done ? done() : 0);
   const result = [];
   let i;
-  for (i = 0; i < PRE_COUNT; i++) result.push(fn());
+  for (i = 0; i < PRE_COUNT; i++) result.push(fn(() => {}));
   const begin = process.hrtime();
-  for (i = 0; i < count; i++) result.push(fn());
-  const end = process.hrtime(begin);
-  const diff = end[0] * 1e9 + end[1];
-  const time = lpad(diff.toString(), '.', 12);
-  name = rpad(name, '.', 12);
-  console.log(name + time + ' nanoseconds');
+  for (i = 0; i < num; i++) result.push(fn(next));
 };
diff --git a/JavaScript/7-functor.js b/JavaScript/7-functor.js
@@ -7,4 +7,4 @@ global.api = {
 const benchmark = require('./6-benchmark');
 const chainFunctor = require('./2-functor');
 const test = require('./4-test');
-benchmark.do(10000, 'Functor', () => test(chainFunctor));
+benchmark.do(20000, 'Functor', (done) => test(chainFunctor, done));
diff --git a/JavaScript/7-promise.js b/JavaScript/7-promise.js
@@ -7,4 +7,4 @@ global.api = {
 const benchmark = require('./6-benchmark');
 const chainPromise = require('./1-promise');
 const test = require('./4-test');
-benchmark.do(10000, 'Promise', () => test(chainPromise));
+benchmark.do(20000, 'Promise', (done) => test(chainPromise, done));
diff --git a/JavaScript/7-prototype.js b/JavaScript/7-prototype.js
@@ -7,4 +7,4 @@ global.api = {
 const benchmark = require('./6-benchmark');
 const chainPrototype = require('./3-prototype');
 const test = require('./4-test');
-benchmark.do(10000, 'Prototype', () => test(chainPrototype));
+benchmark.do(20000, 'Prototype', (done) => test(chainPrototype, done));
