From 7342395f8dd70c0cefa9b1646c48ad1b7a5b5bb8 Mon Sep 17 00:00:00 2001
From: Dominic Tarr <dominic.tarr@gmail.com>
Date: Fri, 6 Jul 2018 11:59:25 -1000
Subject: [PATCH] simpler fix for #5

---
 index.js | 2 ++
 1 file changed, 2 insertions(+)

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