1 files changed, 82 insertions, 0 deletions
diff --git a/deps/npm/node_modules/mississippi/node_modules/stream-each/test.js b/deps/npm/node_modules/mississippi/node_modules/stream-each/test.js
new file mode 100644
index 0000000000..36454c45eb
--- /dev/null
+++ b/deps/npm/node_modules/mississippi/node_modules/stream-each/test.js
@@ -0,0 +1,82 @@
+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()
+  })
+})