summaryrefslogtreecommitdiff
path: root/deps/npm/node_modules/mississippi/node_modules/stream-each/test.js
diff options
context:
space:
mode:
Diffstat (limited to 'deps/npm/node_modules/mississippi/node_modules/stream-each/test.js')
-rw-r--r--deps/npm/node_modules/mississippi/node_modules/stream-each/test.js40
1 files changed, 40 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
index 36454c45eb..277634cd05 100644
--- a/deps/npm/node_modules/mississippi/node_modules/stream-each/test.js
+++ b/deps/npm/node_modules/mississippi/node_modules/stream-each/test.js
@@ -80,3 +80,43 @@ tape('each error and callback', function (t) {
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()
+ })
+})