fix bulkhead max wait time, update dependencies, bump v0.0.8

package.json

@@ -1,6 +1,6 @@
 {
   "name": "mollitia",
-  "version": "0.0.7",
+  "version": "0.0.8",
   "description": "JavaScript Resilience Library",
   "main": "dist/mollitia.umd.js",
   "module": "dist/mollitia.es5.js",

src/helpers/event.ts

@@ -52,7 +52,7 @@ export class EventEmitter {
   public off (eventName: string, cb: EventCallback): void {
     const listeners = this.listeners[eventName];
     if (listeners) {
-      for (let i = listeners.length; i > 0; i--) {
+      for (let i = listeners.length - 1; i > 0; i--) {
         if (listeners[i] === cb) {
           listeners.splice(i, 1);
           break;

src/module/bulkhead.ts

@@ -2,6 +2,8 @@ import { Module, ModuleOptions } from '.';
 import { Circuit, CircuitFunction } from '../circuit';
 import { EventEmitter } from '../helpers/event';
 
+const MAX_TIMEOUT = 2147483647;
+
 /**
  * Properties that customizes the bulkhead behavior.
  */
@@ -123,12 +125,15 @@ export class Bulkhead extends Module {
         this.concurrentBuffer.push(ref);
       } else if (this.queueBuffer.length < this.queueSize) {
         this.queueBuffer.push(ref);
-        const timeout = setTimeout(() => {
-          this.queueBuffer.splice(this.queueBuffer.indexOf(ref), 1);
-          resolveDisposable.dispose();
-          rejectDisposable.dispose();
-          reject(new BulkheadQueueWaitError());
-        }, this.maxQueueWait);
+        let timeout: number;
+        if (this.maxQueueWait <= MAX_TIMEOUT) {
+          timeout = <unknown>setTimeout(() => {
+            this.queueBuffer.splice(this.queueBuffer.indexOf(ref), 1);
+            resolveDisposable.dispose();
+            rejectDisposable.dispose();
+            reject(new BulkheadQueueWaitError());
+          }, this.maxQueueWait) as number;
+        }
         const executeDisposable = ref.on('execute', () => {
           executeDisposable.dispose();
           clearTimeout(timeout);