Merge e11b78a into afd4710

lib/index.js

@@ -36,6 +36,7 @@ function Reissue(opts) {
     assert.optionalObject(opts.context, 'context');
     assert.optionalArray(opts.args, 'args');
     assert.optionalNumber(opts.timeout, 'timeout');
+    assert.optionalBool(opts.unref, 'unref');
 
     // assert options of different types
     const typeofInterval = typeof opts.interval;
@@ -93,6 +94,13 @@ function Reissue(opts) {
      */
     self._timeoutMs = opts.timeout || null;
 
+    /**
+     * unref the timeout
+     * @private
+     * @type {Boolean}
+     */
+    self._unref = opts.unref;
+
     //--------------------------------------------------------------------------
     // internal properties
     //--------------------------------------------------------------------------
@@ -173,6 +181,9 @@ Reissue.prototype._execute = function _execute() {
             bind(self._onTimeout, self),
             self._timeoutMs
         );
+        if (self._unref) {
+            self._timeoutHandlerId.unref();
+        }
     }
 };
 
@@ -228,6 +239,9 @@ Reissue.prototype._done = function _done(err) {
             self._nextHandlerId = setTimeout(function _nextInvocation() {
                 self._execute();
             }, timeToInvocation);
+            if (self._unref) {
+                self._nextHandlerId.unref();
+            }
         }
     }
 };
@@ -309,6 +323,9 @@ Reissue.prototype.start = function start(delay) {
         self._nextHandlerId = setTimeout(function _nextInvocation() {
             self._execute();
         }, delay);
+        if (self._unref) {
+            self._nextHandlerId.unref();
+        }
     } else {
         self._execute();
     }