Check for heartbeat before referencing it

SGrondin · Jul 6, 2019 · 5978fdf · 5978fdf
1 parent d5d353b
commit 5978fdf
Show file tree

Hide file tree

Showing 4 changed files with 14 additions and 14 deletions.
diff --git a/es5.js b/es5.js
@@ -4359,13 +4359,13 @@
 	      }.call(this);
 
 	      this._queues.on("leftzero", function () {
-	        var base;
-	        return typeof (base = _this._store.heartbeat).ref === "function" ? base.ref() : void 0;
+	        var ref;
+	        return (ref = _this._store.heartbeat) != null ? typeof ref.ref === "function" ? ref.ref() : void 0 : void 0;
 	      });
 
 	      this._queues.on("zero", function () {
-	        var base;
-	        return typeof (base = _this._store.heartbeat).unref === "function" ? base.unref() : void 0;
+	        var ref;
+	        return (ref = _this._store.heartbeat) != null ? typeof ref.unref === "function" ? ref.unref() : void 0 : void 0;
 	      });
 	    }
 

diff --git a/lib/Bottleneck.js b/lib/Bottleneck.js
@@ -70,13 +70,13 @@ Bottleneck = function () {
       }.call(this);
 
       this._queues.on("leftzero", () => {
-        var base;
-        return typeof (base = this._store.heartbeat).ref === "function" ? base.ref() : void 0;
+        var ref;
+        return (ref = this._store.heartbeat) != null ? typeof ref.ref === "function" ? ref.ref() : void 0 : void 0;
       });
 
       this._queues.on("zero", () => {
-        var base;
-        return typeof (base = this._store.heartbeat).unref === "function" ? base.unref() : void 0;
+        var ref;
+        return (ref = this._store.heartbeat) != null ? typeof ref.unref === "function" ? ref.unref() : void 0 : void 0;
       });
     }
 

diff --git a/light.js b/light.js
@@ -1080,12 +1080,12 @@
 	        }
 	      }).call(this);
 	      this._queues.on("leftzero", () => {
-	        var base;
-	        return typeof (base = this._store.heartbeat).ref === "function" ? base.ref() : void 0;
+	        var ref;
+	        return (ref = this._store.heartbeat) != null ? typeof ref.ref === "function" ? ref.ref() : void 0 : void 0;
 	      });
 	      this._queues.on("zero", () => {
-	        var base;
-	        return typeof (base = this._store.heartbeat).unref === "function" ? base.unref() : void 0;
+	        var ref;
+	        return (ref = this._store.heartbeat) != null ? typeof ref.unref === "function" ? ref.unref() : void 0 : void 0;
 	      });
 	    }
 

diff --git a/src/Bottleneck.coffee b/src/Bottleneck.coffee
@@ -83,8 +83,8 @@ class Bottleneck
     else
       throw new Bottleneck::BottleneckError "Invalid datastore type: #{@datastore}"
 
-    @_queues.on "leftzero", => @_store.heartbeat.ref?()
-    @_queues.on "zero", => @_store.heartbeat.unref?()
+    @_queues.on "leftzero", => @_store.heartbeat?.ref?()
+    @_queues.on "zero", => @_store.heartbeat?.unref?()
 
   _validateOptions: (options, invalid) ->
     unless options? and typeof options == "object" and invalid.length == 0