fix(BlockStream): don't emit 'from' block

mappum · Jan 14, 2016 · 831168a · 831168a
1 parent eba2aea
commit 831168a
Showing 1 changed file with 8 additions and 3 deletions.
diff --git a/lib/blockStream.js b/lib/blockStream.js
@@ -51,10 +51,15 @@ BlockStream.prototype._next = function () {
   if (!this.requestCursor) return
   this.chain.getBlock(this.requestCursor, function (err, block) {
     if (err) return self._error(err)
+    if (!self._from) self._from = block
     var hash = u.toHash(block.header.hash)
-    if (self.requestHeight == null) self.requestHeight = block.height
-    self.requestQueue.push(hash)
-    self._getData(block)
+    if (block.height > self._from.height) {
+      if (self.requestHeight == null) {
+        self.requestHeight = block.height
+      }
+      self.requestQueue.push(hash)
+      self._getData(block)
+    }
     if (!block.next) {
       return self.requestQueue.push(null)
     }