Merge pull request #2 from guybedford/read-debounce

Handle next call debouncing

Author: mcollina

index.js

@@ -13,8 +13,14 @@ function toReadable (iterator, opts) {
     readable.destroy(err)
   }
 
+  let curNext
   async function next () {
-    const { value, done } = await iterator.next()
+    if (curNext) {
+      await curNext
+      return
+    }
+    const { value, done } = await (curNext = iterator.next())
+    curNext = null
     if (done) {
       readable.push(null)
       return