bug: ensure pending close flag is reset

nodeshift · Dec 20, 2016 · 35b5be1 · 35b5be1
1 parent cc2c01a
commit 35b5be1
Showing 1 changed file with 2 additions and 0 deletions.
diff --git a/lib/circuit.js b/lib/circuit.js
@@ -70,6 +70,7 @@ class CircuitBreaker extends EventEmitter {
    */
   close () {
     this[NUM_FAILURES] = 0;
+    this[PENDING_CLOSE] = false;
     if (this[STATE] !== CLOSED) {
       this[STATE] = CLOSED;
       this.emit('close');
@@ -82,6 +83,7 @@ class CircuitBreaker extends EventEmitter {
    * that has been provided.
    */
   open () {
+    this[PENDING_CLOSE] = false;
     if (this[STATE] !== OPEN) {
       this[STATE] = OPEN;
       this.emit('open');