summaryrefslogtreecommitdiffstats
path: root/node_modules/stream-each
diff options
context:
space:
mode:
Diffstat (limited to 'node_modules/stream-each')
-rw-r--r--node_modules/stream-each/.travis.yml5
-rw-r--r--node_modules/stream-each/LICENSE21
-rw-r--r--node_modules/stream-each/README.md41
-rw-r--r--node_modules/stream-each/collaborators.md7
-rw-r--r--node_modules/stream-each/index.js59
-rw-r--r--node_modules/stream-each/package.json57
-rw-r--r--node_modules/stream-each/test.js143
7 files changed, 0 insertions, 333 deletions
diff --git a/node_modules/stream-each/.travis.yml b/node_modules/stream-each/.travis.yml
deleted file mode 100644
index aa89858..0000000
--- a/node_modules/stream-each/.travis.yml
+++ /dev/null
@@ -1,5 +0,0 @@
-language: node_js
-node_js:
- - '0.10'
- - '0.12'
- - 'stable'
diff --git a/node_modules/stream-each/LICENSE b/node_modules/stream-each/LICENSE
deleted file mode 100644
index 66a4d2a..0000000
--- a/node_modules/stream-each/LICENSE
+++ /dev/null
@@ -1,21 +0,0 @@
-The MIT License (MIT)
-
-Copyright (c) 2015 Mathias Buus
-
-Permission is hereby granted, free of charge, to any person obtaining a copy
-of this software and associated documentation files (the "Software"), to deal
-in the Software without restriction, including without limitation the rights
-to use, copy, modify, merge, publish, distribute, sublicense, and/or sell
-copies of the Software, and to permit persons to whom the Software is
-furnished to do so, subject to the following conditions:
-
-The above copyright notice and this permission notice shall be included in
-all copies or substantial portions of the Software.
-
-THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR
-IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY,
-FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE
-AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER
-LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM,
-OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN
-THE SOFTWARE.
diff --git a/node_modules/stream-each/README.md b/node_modules/stream-each/README.md
deleted file mode 100644
index e0832d5..0000000
--- a/node_modules/stream-each/README.md
+++ /dev/null
@@ -1,41 +0,0 @@
-# stream-each
-
-Iterate all the data in a stream
-
-```
-npm install stream-each
-```
-
-[![build status](http://img.shields.io/travis/mafintosh/stream-each.svg?style=flat)](http://travis-ci.org/mafintosh/stream-each)
-
-## Usage
-
-``` js
-var each = require('stream-each')
-
-each(stream, function (data, next) {
- console.log('data from stream', data)
- // when ready to consume next chunk
- next()
-}, function (err) {
- console.log('no more data')
-})
-```
-
-## API
-
-#### `each(stream, iterator, cb)`
-
-Iterate the data in the stream by calling the iterator function with `(data, next)`
-where data is a data chunk and next is a callback. Call next when you are ready to
-consume the next chunk. Optionally you can call next with an error to destroy the stream
-
-When the stream ends/errors the callback is called if provided
-
-## License
-
-MIT
-
-## Related
-
-`stream-each` is part of the [mississippi stream utility collection](https://github.com/maxogden/mississippi) which includes more useful stream modules similar to this one.
diff --git a/node_modules/stream-each/collaborators.md b/node_modules/stream-each/collaborators.md
deleted file mode 100644
index fc16de2..0000000
--- a/node_modules/stream-each/collaborators.md
+++ /dev/null
@@ -1,7 +0,0 @@
-## Collaborators
-
-stream-each is only possible due to the excellent work of the following collaborators:
-
-<table><tbody><tr><th align="left">maxogden</th><td><a href="https://github.com/maxogden">GitHub/maxogden</a></td></tr>
-<tr><th align="left">mafintosh</th><td><a href="https://github.com/mafintosh">GitHub/mafintosh</a></td></tr>
-</tbody></table>
diff --git a/node_modules/stream-each/index.js b/node_modules/stream-each/index.js
deleted file mode 100644
index 6d65b57..0000000
--- a/node_modules/stream-each/index.js
+++ /dev/null
@@ -1,59 +0,0 @@
-var eos = require('end-of-stream')
-var shift = require('stream-shift')
-
-module.exports = each
-
-function each (stream, fn, cb) {
- var want = true
- var error = null
- var ended = false
- var running = false
- var calling = false
-
- stream.on('readable', onreadable)
- onreadable()
-
- if (cb) eos(stream, {readable: true, writable: false}, done)
- return stream
-
- function done (err) {
- if (!error) error = err
- ended = true
- if (!running) cb(error)
- }
-
- function onreadable () {
- if (want) read()
- }
-
- function afterRead (err) {
- running = false
-
- if (err) {
- error = err
- if (ended) return cb(error)
- stream.destroy(err)
- return
- }
- if (ended) return cb(error)
- if (!calling) read()
- }
-
- function read () {
- while (!running && !ended) {
- want = false
-
- var data = shift(stream)
- if (ended) return
- if (data === null) {
- want = true
- return
- }
-
- running = true
- calling = true
- fn(data, afterRead)
- calling = false
- }
- }
-}
diff --git a/node_modules/stream-each/package.json b/node_modules/stream-each/package.json
deleted file mode 100644
index fabb774..0000000
--- a/node_modules/stream-each/package.json
+++ /dev/null
@@ -1,57 +0,0 @@
-{
- "_from": "stream-each@^1.1.0",
- "_id": "stream-each@1.2.3",
- "_inBundle": false,
- "_integrity": "sha512-vlMC2f8I2u/bZGqkdfLQW/13Zihpej/7PmSiMQsbYddxuTsJp8vRe2x2FvVExZg7FaOds43ROAuFJwPR4MTZLw==",
- "_location": "/stream-each",
- "_phantomChildren": {},
- "_requested": {
- "type": "range",
- "registry": true,
- "raw": "stream-each@^1.1.0",
- "name": "stream-each",
- "escapedName": "stream-each",
- "rawSpec": "^1.1.0",
- "saveSpec": null,
- "fetchSpec": "^1.1.0"
- },
- "_requiredBy": [
- "/mississippi"
- ],
- "_resolved": "https://registry.npmjs.org/stream-each/-/stream-each-1.2.3.tgz",
- "_shasum": "ebe27a0c389b04fbcc233642952e10731afa9bae",
- "_spec": "stream-each@^1.1.0",
- "_where": "/home/pruss/Dev/3-minute-website/node_modules/mississippi",
- "author": {
- "name": "Mathias Buus",
- "url": "@mafintosh"
- },
- "bugs": {
- "url": "https://github.com/mafintosh/stream-each/issues"
- },
- "bundleDependencies": false,
- "dependencies": {
- "end-of-stream": "^1.1.0",
- "stream-shift": "^1.0.0"
- },
- "deprecated": false,
- "description": "Iterate all the data in a stream",
- "devDependencies": {
- "ndjson": "^1.5.0",
- "standard": "^5.3.1",
- "tape": "^4.2.1",
- "through2": "^2.0.0"
- },
- "homepage": "https://github.com/mafintosh/stream-each",
- "license": "MIT",
- "main": "index.js",
- "name": "stream-each",
- "repository": {
- "type": "git",
- "url": "git+https://github.com/mafintosh/stream-each.git"
- },
- "scripts": {
- "test": "standard && tape test.js"
- },
- "version": "1.2.3"
-}
diff --git a/node_modules/stream-each/test.js b/node_modules/stream-each/test.js
deleted file mode 100644
index a466595..0000000
--- a/node_modules/stream-each/test.js
+++ /dev/null
@@ -1,143 +0,0 @@
-var tape = require('tape')
-var through = require('through2')
-var ndjson = require('ndjson')
-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()
- })
-})
-
-tape('cb only once', function (t) {
- var p = ndjson.parse()
- var once = true
- var data = '{"foo":"' + Array(1000).join('x') + '"}\n'
-
- each(p, ondata, function (err) {
- t.ok(once, 'only once')
- t.ok(err, 'had error')
- once = false
- t.end()
- })
-
- for (var i = 0; i < 1000; i++) p.write(data)
- p.write('{...}\n')
-
- function ondata (data, cb) {
- process.nextTick(cb)
- }
-})
generated by cgit v1.2.3 (git 2.25.1) at 2025-08-23 16:27:51 +0000