diff --git a/index.js b/index.js
index ece86c2..d504a10 100644
--- 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