1 files changed, 122 insertions, 0 deletions
diff --git a/deps/npm/node_modules/cacache/node_modules/mississippi/node_modules/stream-each/test.js b/deps/npm/node_modules/cacache/node_modules/mississippi/node_modules/stream-each/test.js
new file mode 100644
index 0000000000..277634cd05
--- /dev/null
+++ b/deps/npm/node_modules/cacache/node_modules/mississippi/node_modules/stream-each/test.js
@@ -0,0 +1,122 @@
+var tape = require('tape')
+var through = require('through2')
+var each = require('./')
+
+tape('each', function (t) {
+  var s = through.obj()
+  s.write('a')
+  s.write('b')
+  s.write('c')
+  s.end()
+
+  s.on('end', function () {
+    t.end()
+  })
+
+  var expected = ['a', 'b', 'c']
+  each(s, function (data, next) {
+    t.same(data, expected.shift())
+    next()
+  })
+})
+
+tape('each and callback', function (t) {
+  var s = through.obj()
+  s.write('a')
+  s.write('b')
+  s.write('c')
+  s.end()
+
+  var expected = ['a', 'b', 'c']
+  each(s, function (data, next) {
+    t.same(data, expected.shift())
+    next()
+  }, function () {
+    t.end()
+  })
+})
+
+tape('each (write after)', function (t) {
+  var s = through.obj()
+  s.on('end', function () {
+    t.end()
+  })
+
+  var expected = ['a', 'b', 'c']
+  each(s, function (data, next) {
+    t.same(data, expected.shift())
+    next()
+  })
+
+  setTimeout(function () {
+    s.write('a')
+    s.write('b')
+    s.write('c')
+    s.end()
+  }, 100)
+})
+
+tape('each error', function (t) {
+  var s = through.obj()
+  s.write('hello')
+  s.on('error', function (err) {
+    t.same(err.message, 'stop')
+    t.end()
+  })
+
+  each(s, function (data, next) {
+    next(new Error('stop'))
+  })
+})
+
+tape('each error and callback', function (t) {
+  var s = through.obj()
+  s.write('hello')
+
+  each(s, function (data, next) {
+    next(new Error('stop'))
+  }, function (err) {
+    t.same(err.message, 'stop')
+    t.end()
+  })
+})
+
+tape('each with falsey values', function (t) {
+  var s = through.obj()
+  s.write(0)
+  s.write(false)
+  s.write(undefined)
+  s.end()
+
+  s.on('end', function () {
+    t.end()
+  })
+
+  var expected = [0, false]
+  var count = 0
+  each(s, function (data, next) {
+    count++
+    t.same(data, expected.shift())
+    next()
+  }, function () {
+    t.same(count, 2)
+  })
+})
+
+tape('huge stack', function (t) {
+  var s = through.obj()
+
+  for (var i = 0; i < 5000; i++) {
+    s.write('foo')
+  }
+
+  s.end()
+
+  each(s, function (data, cb) {
+    if (data !== 'foo') t.fail('bad data')
+    cb()
+  }, function (err) {
+    t.error(err, 'no error')
+    t.end()
+  })
+})