fix: semaphore is part of the class

as property
nodeshift · Jun 13, 2017 · 0faa766 · 0faa766
1 parent e62a569
commit 0faa766
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/lib/circuit.js b/lib/circuit.js
@@ -52,6 +52,7 @@ class CircuitBreaker extends EventEmitter {
     this.options.rollingCountBuckets = options.rollingCountBuckets || 10;
     this.options.rollingPercentilesEnabled = options.rollingPercentilesEnabled !== false;
     this.options.capacity = options.capacity || 10;
+    this.semaphore = new Semaphore(this.options.capacity);
 
     this[STATUS] = new Status(this.options);
     this[STATE] = CLOSED;
@@ -237,7 +238,6 @@ class CircuitBreaker extends EventEmitter {
    * @fires CircuitBreaker#timeout
    */
   fire () {
-    const semaphore = new Semaphore(this.options.capacity);
     const args = Array.prototype.slice.call(arguments);
 
     /**
@@ -277,7 +277,7 @@ class CircuitBreaker extends EventEmitter {
 
     let timeout;
     let timeoutError = false;
-    return semaphore.use(() => {
+    return this.semaphore.use(() => {
       return new Promise((resolve, reject) => {
         const latencyStartTime = Date.now();
         timeout = setTimeout(