1 files changed, 70 insertions, 0 deletions
diff --git a/deps/npm/node_modules/stream-iterate/index.js b/deps/npm/node_modules/stream-iterate/index.js
new file mode 100644
index 0000000000..c60d6ab550
--- /dev/null
+++ b/deps/npm/node_modules/stream-iterate/index.js
@@ -0,0 +1,70 @@
+var Readable = require('readable-stream').Readable
+var shift = require('stream-shift')
+
+var stream2 = function (stream) {
+  if (stream._readableState) return stream
+  return new Readable({objectMode: true, highWaterMark: 16}).wrap(stream)
+}
+
+module.exports = function (stream) {
+  stream = stream2(stream)
+
+  var ended = false
+  var data = null
+  var err = null
+  var destroyed = false
+  var fn = null
+
+  var consume = function (e) {
+    if (e) {
+      destroyed = true
+      if (stream.destroy) stream.destroy(e)
+      return
+    }
+
+    data = null
+    err = null
+  }
+
+  var onresult = function () {
+    if (!fn) return
+    var tmp = fn
+    fn = undefined
+    tmp(err, data, consume)
+  }
+
+  var update = function () {
+    if (!fn) return
+    data = shift(stream)
+    if (data === null && !ended) return
+    onresult()
+  }
+
+  var onend = function () {
+    ended = true
+    onresult()
+  }
+
+  stream.on('readable', update)
+
+  stream.on('error', function (e) {
+    err = e
+    onresult()
+  })
+
+  stream.on('close', function () {
+    if (stream._readableState.ended) return
+    onend()
+  })
+
+  stream.on('end', onend)
+
+  return function (callback) {
+    if (destroyed) return
+    if (err) return callback(err, null, consume)
+    if (data) return callback(null, data, consume)
+    if (ended) return callback(null, null, consume)
+    fn = callback
+    update()
+  }
+}