test: running fire in parallel

Also new devDependency added run-parallel: 1.1.6
nodeshift · Jun 16, 2017 · 3d990c3 · 3d990c3
1 parent 31b6d64
commit 3d990c3
Show file tree

Hide file tree

Showing 2 changed files with 63 additions and 0 deletions.
diff --git a/package.json b/package.json
@@ -63,6 +63,7 @@
     "jsdoc": "~3.4.2",
     "nsp": "~2.6.2",
     "opener": "~1.4.2",
+    "run-parallel": "^1.1.6",
     "standard-version": "^4.0.0",
     "szero": "^0.9.0",
     "tap-spec": "~4.1.1",

diff --git a/test/test.js b/test/test.js
@@ -742,6 +742,68 @@ test('Semaphore capacity limit', (t) => {
     });
 });
 
+test('Semaphore capacity limit in parallel', (t) => {
+  const parallel = require('run-parallel');
+  t.plan(24);
+  const breaker = cb('foobar', { capacity: 1 });
+
+  const tasks = [
+    () => {
+      breaker.fire()
+      .then((result) => {
+        t.ok(true, `semaphore count is: ${breaker.semaphore.count} and initial capacity is: ${breaker.options.capacity}`);
+        t.ok(true, `failures: ${breaker.stats.failures}`);
+        t.ok(true, `fallbacks: ${breaker.stats.fallbacks}`);
+        t.ok(true, `successes: ${breaker.stats.successes}`);
+        t.ok(true, `rejects: ${breaker.stats.rejects}`);
+        t.ok(true, `fires: ${breaker.stats.fires}`);
+      })
+      .catch(t.fail);
+    },
+    () => {
+      breaker.fire()
+      .then((result) => {
+        t.ok(true, `semaphore count is: ${breaker.semaphore.count} and initial capacity is: ${breaker.options.capacity}`);
+        t.ok(true, `failures: ${breaker.stats.failures}`);
+        t.ok(true, `fallbacks: ${breaker.stats.fallbacks}`);
+        t.ok(true, `successes: ${breaker.stats.successes}`);
+        t.ok(true, `rejects: ${breaker.stats.rejects}`);
+        t.ok(true, `fires: ${breaker.stats.fires}`);
+      })
+      .catch(t.fail);
+    },
+    () => {
+      breaker.fire()
+      .then((result) => {
+        t.ok(true, `semaphore count is: ${breaker.semaphore.count} and initial capacity is: ${breaker.options.capacity}`);
+        t.ok(true, `failures: ${breaker.stats.failures}`);
+        t.ok(true, `fallbacks: ${breaker.stats.fallbacks}`);
+        t.ok(true, `successes: ${breaker.stats.successes}`);
+        t.ok(true, `rejects: ${breaker.stats.rejects}`);
+        t.ok(true, `fires: ${breaker.stats.fires}`);
+      })
+      .catch(t.fail);
+    }
+  ];
+
+  parallel(tasks, (error) => {
+    t.error(error);
+    t.fail();
+  });
+
+  breaker.fire()
+    .then((result) => {
+      t.ok(true, `This is not in parallel -> semaphore count is: ${breaker.semaphore.count} and initial capacity is: ${breaker.options.capacity}`);
+      t.ok(true, `failures: ${breaker.stats.failures}`);
+      t.ok(true, `fallbacks: ${breaker.stats.fallbacks}`);
+      t.ok(true, `successes: ${breaker.stats.successes}`);
+      t.ok(true, `rejects: ${breaker.stats.rejects}`);
+      t.ok(true, `fires: ${breaker.stats.fires}`);
+    })
+    .then(t.end)
+    .catch(t.fail);
+});
+
 /**
  * Returns a promise that resolves if the parameter
  * 'x' evaluates to >= 0. Otherwise the returned promise fails.