diff --git a/lib/circuit.js b/lib/circuit.js index 83ed894b..ad770488 100644 --- 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');