make sure we dont close the stream until async indicators are done, fix

#2522
askmike · Sep 16, 2018 · 369a8e9 · 369a8e9
1 parent 22677be
commit 369a8e9
Show file tree

Hide file tree

Showing 2 changed files with 1 addition and 1 deletion.
diff --git a/core/gekkoStream.js b/core/gekkoStream.js
@@ -94,6 +94,7 @@ Gekko.prototype.finalize = function() {
 }
 
 Gekko.prototype.shutdown = function() {
+  this.end();
   async.eachSeries(
     this.plugins,
     function(c, callback) {

diff --git a/core/markets/backtest.js b/core/markets/backtest.js
@@ -74,7 +74,6 @@ Market.prototype.processCandles = function(err, candles) {
     if(this.ended) {
       this.closed = true;
       this.reader.close();
-      this.emit('end');
     } else {
       util.die('Query returned no candles (do you have local data for the specified range?)');
     }