make sure to flush the batcher, fix #2329

askmike · Aug 29, 2018 · 60b6eb8 · 60b6eb8
1 parent eb30a7b
commit 60b6eb8
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 2 deletions.
diff --git a/core/tools/dataStitcher.js b/core/tools/dataStitcher.js
@@ -223,6 +223,7 @@ Stitcher.prototype.seedLocalData = function(from, to, next) {
     });
 
     this.batcher.write(rows);
+    this.batcher.flush();
     this.reader.close();
     next();
 

diff --git a/plugins/tradingAdvisor/tradingAdvisor.js b/plugins/tradingAdvisor/tradingAdvisor.js
@@ -92,14 +92,15 @@ Actor.prototype.processCandle = function(candle, done) {
     this.next = done;
   } else {
     done();
-    this.next = _.noop;
+    this.next = false;
   }
   this.batcher.flush();
 }
 
 // propogate a custom sized candle to the trading strategy
 Actor.prototype.emitStratCandle = function(candle) {
-  this.strategy.tick(candle, this.next);
+  const next = this.next || _.noop;
+  this.strategy.tick(candle, next);
 }
 
 Actor.prototype.processTradeCompleted = function(trade) {