Clear interval rather than relying on unref()

Fixes artilleryio#264
hassy · Mar 8, 2017 · c4424a4 · c4424a4
1 parent 619112e
commit c4424a4
Showing 1 changed file with 3 additions and 2 deletions.
diff --git a/lib/runner.js b/lib/runner.js
@@ -106,9 +106,9 @@ Runner.prototype.run = function run() {
   });
 
   // TODO: Use nanotimer
-  setInterval(
+  this._statsInterval = setInterval(
     this._sendStats.bind(this),
-    this._script.config.statsInterval * 1000).unref();
+    this._script.config.statsInterval * 1000);
   return this;
 };
 
@@ -197,6 +197,7 @@ Runner.prototype._onWorkerMessage = function _onWorkerMessage(message) {
   }
 
   if (message.event === 'done') {
+    clearInterval(this._statsInterval);
     let worker = this._workers[message.pid];
     worker.isDone = true;
     worker.proc.send({command: 'stop'});