simpler fix for #5

dominictarr · Jul 6, 2018 · 7342395 · 7342395
1 parent a081c23
commit 7342395
Showing 1 changed file with 2 additions and 0 deletions.
diff --git a/index.js b/index.js
@@ -38,6 +38,8 @@ module.exports = function (timeout) {
         var next = queue.shift()
         next.cb(null, state.get(next.length))
       }
+      else if(ended == true && queue[0].length && state.length < queue[0].length)
+        queue.shift().cb(new Error('stream ended with:'+state.length+' but wanted:'+queue.length))
       else if(ended)
         queue.shift().cb(ended)
       else