diff options
Diffstat (limited to 'deps/npm/node_modules/mississippi')
43 files changed, 545 insertions, 591 deletions
diff --git a/deps/npm/node_modules/mississippi/.npmignore b/deps/npm/node_modules/mississippi/.npmignore new file mode 100644 index 0000000000..b512c09d47 --- /dev/null +++ b/deps/npm/node_modules/mississippi/.npmignore @@ -0,0 +1 @@ +node_modules
\ No newline at end of file diff --git a/deps/npm/node_modules/mississippi/changelog.md b/deps/npm/node_modules/mississippi/changelog.md deleted file mode 100644 index 75333b0844..0000000000 --- a/deps/npm/node_modules/mississippi/changelog.md +++ /dev/null @@ -1,10 +0,0 @@ -# mississippi Change Log -All notable changes to this project will be documented in this file. -This project adheres to [Semantic Versioning](http://semver.org/). - -## 3.0.0 - 2018-02-26 -* Update to pump@3.0.0. Returns the last stream the pipeline to enable chaining. (Use the individual modules to avoid potentially unnecessary major updates in your project). - -## 2.0.0 - 2018-01-30 -* Update to pump@2.0.1. (Use the individual modules to avoid potentially unnecessary major updates in your project) -* Pin engines support to >= Node 4.0.0. Run Node LTS or greater. diff --git a/deps/npm/node_modules/mississippi/index.js b/deps/npm/node_modules/mississippi/index.js index d635b29c56..da3de5e0a7 100644 --- a/deps/npm/node_modules/mississippi/index.js +++ b/deps/npm/node_modules/mississippi/index.js @@ -7,4 +7,3 @@ module.exports.concat = require('concat-stream') module.exports.finished = require('end-of-stream') module.exports.from = require('from2') module.exports.to = require('flush-write-stream') -module.exports.parallel = require('parallel-transform') diff --git a/deps/npm/node_modules/mississippi/license b/deps/npm/node_modules/mississippi/license deleted file mode 100644 index e34763968c..0000000000 --- a/deps/npm/node_modules/mississippi/license +++ /dev/null @@ -1,7 +0,0 @@ -Redistribution and use in source and binary forms, with or without modification, are permitted provided that the following conditions are met: - -1. Redistributions of source code must retain the above copyright notice, this list of conditions and the following disclaimer. - -2. Redistributions in binary form must reproduce the above copyright notice, this list of conditions and the following disclaimer in the documentation and/or other materials provided with the distribution. - -THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS "AS IS" AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT HOLDER OR CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE. diff --git a/deps/npm/node_modules/mississippi/node_modules/concat-stream/package.json b/deps/npm/node_modules/mississippi/node_modules/concat-stream/package.json index 3d8b508cf9..3ec39aba0e 100644 --- a/deps/npm/node_modules/mississippi/node_modules/concat-stream/package.json +++ b/deps/npm/node_modules/mississippi/node_modules/concat-stream/package.json @@ -1,8 +1,7 @@ { "_from": "concat-stream@^1.5.0", - "_id": "concat-stream@1.6.1", - "_inBundle": false, - "_integrity": "sha512-gslSSJx03QKa59cIKqeJO9HQ/WZMotvYJCuaUULrLpjj8oG40kV2Z+gz82pVxlTkOADi4PJxQPPfhl1ELYrrXw==", + "_id": "concat-stream@1.6.0", + "_integrity": "sha1-CqxmL9Ur54lk1VMvaUeE5wEQrPc=", "_location": "/mississippi/concat-stream", "_phantomChildren": {}, "_requested": { @@ -18,14 +17,16 @@ "_requiredBy": [ "/mississippi" ], - "_resolved": "https://registry.npmjs.org/concat-stream/-/concat-stream-1.6.1.tgz", - "_shasum": "261b8f518301f1d834e36342b9fea095d2620a26", + "_resolved": "https://registry.npmjs.org/concat-stream/-/concat-stream-1.6.0.tgz", + "_shasum": "0aac662fd52be78964d5532f694784e70110acf7", + "_shrinkwrap": null, "_spec": "concat-stream@^1.5.0", "_where": "/Users/zkat/Documents/code/npm/node_modules/mississippi", "author": { "name": "Max Ogden", "email": "max@maxogden.com" }, + "bin": null, "bugs": { "url": "http://github.com/maxogden/concat-stream/issues" }, @@ -50,6 +51,8 @@ "license": "MIT", "main": "index.js", "name": "concat-stream", + "optionalDependencies": {}, + "peerDependencies": {}, "repository": { "type": "git", "url": "git+ssh://git@github.com/maxogden/concat-stream.git" @@ -79,5 +82,5 @@ "android-browser/4.2..latest" ] }, - "version": "1.6.1" + "version": "1.6.0" } diff --git a/deps/npm/node_modules/mississippi/node_modules/duplexify/.npmignore b/deps/npm/node_modules/mississippi/node_modules/duplexify/.npmignore new file mode 100644 index 0000000000..3c3629e647 --- /dev/null +++ b/deps/npm/node_modules/mississippi/node_modules/duplexify/.npmignore @@ -0,0 +1 @@ +node_modules diff --git a/deps/npm/node_modules/mississippi/node_modules/duplexify/README.md b/deps/npm/node_modules/mississippi/node_modules/duplexify/README.md index 8352900fc6..27669f6b6b 100644 --- a/deps/npm/node_modules/mississippi/node_modules/duplexify/README.md +++ b/deps/npm/node_modules/mississippi/node_modules/duplexify/README.md @@ -46,7 +46,7 @@ If you call `setReadable` or `setWritable` multiple times it will unregister the To disable the readable or writable part call `setReadable` or `setWritable` with `null`. If the readable or writable streams emits an error or close it will destroy both streams and bubble up the event. -You can also explicitly destroy the streams by calling `dup.destroy()`. The `destroy` method optionally takes an +You can also explictly destroy the streams by calling `dup.destroy()`. The `destroy` method optionally takes an error object as argument, in which case the error is emitted as part of the `error` event. ``` js diff --git a/deps/npm/node_modules/mississippi/node_modules/duplexify/index.js b/deps/npm/node_modules/mississippi/node_modules/duplexify/index.js index 8323e654ac..a04f124fa9 100644 --- a/deps/npm/node_modules/mississippi/node_modules/duplexify/index.js +++ b/deps/npm/node_modules/mississippi/node_modules/duplexify/index.js @@ -3,9 +3,7 @@ var eos = require('end-of-stream') var inherits = require('inherits') var shift = require('stream-shift') -var SIGNAL_FLUSH = (Buffer.from && Buffer.from !== Uint8Array.from) - ? Buffer.from([0]) - : new Buffer([0]) +var SIGNAL_FLUSH = new Buffer([0]) var onuncork = function(self, fn) { if (self._corked) self.once('uncork', fn) @@ -14,7 +12,7 @@ var onuncork = function(self, fn) { var destroyer = function(self, end) { return function(err) { - if (err) self._destroyInterval(err) + if (err) self.destroy(err.message === 'premature close' ? null : err) else if (end && !self._ended) self.end() } } @@ -48,8 +46,6 @@ var Duplexify = function(writable, readable, opts) { this._unwrite = null this._unread = null this._ended = false - this._error = null - this._preferError = false this.destroyed = false @@ -171,24 +167,15 @@ Duplexify.prototype._forward = function() { } Duplexify.prototype.destroy = function(err) { - if (this._preferError && !this._error && err) this._error = err - if (this.destroyed) return this.destroyed = true var self = this process.nextTick(function() { - self._destroy(self._preferError ? self._error : err) + self._destroy(err) }) } -Duplexify.prototype._destroyInterval = function(err) { - if (this.destroyed) return - if (err.message !== 'premature close') return this.destroy(err) - this._preferError = true - this.destroy(null) -} - Duplexify.prototype._destroy = function(err) { if (err) { var ondrain = this._ondrain diff --git a/deps/npm/node_modules/mississippi/node_modules/duplexify/node_modules/end-of-stream/.npmignore b/deps/npm/node_modules/mississippi/node_modules/duplexify/node_modules/end-of-stream/.npmignore new file mode 100644 index 0000000000..3c3629e647 --- /dev/null +++ b/deps/npm/node_modules/mississippi/node_modules/duplexify/node_modules/end-of-stream/.npmignore @@ -0,0 +1 @@ +node_modules diff --git a/deps/npm/node_modules/mississippi/node_modules/duplexify/node_modules/end-of-stream/README.md b/deps/npm/node_modules/mississippi/node_modules/duplexify/node_modules/end-of-stream/README.md new file mode 100644 index 0000000000..df800c1eb6 --- /dev/null +++ b/deps/npm/node_modules/mississippi/node_modules/duplexify/node_modules/end-of-stream/README.md @@ -0,0 +1,47 @@ +# end-of-stream + +A node module that calls a callback when a readable/writable/duplex stream has completed or failed. + + npm install end-of-stream + +## Usage + +Simply pass a stream and a callback to the `eos`. +Both legacy streams and streams2 are supported. + +``` js +var eos = require('end-of-stream'); + +eos(readableStream, function(err) { + if (err) return console.log('stream had an error or closed early'); + console.log('stream has ended'); +}); + +eos(writableStream, function(err) { + if (err) return console.log('stream had an error or closed early'); + console.log('stream has finished'); +}); + +eos(duplexStream, function(err) { + if (err) return console.log('stream had an error or closed early'); + console.log('stream has ended and finished'); +}); + +eos(duplexStream, {readable:false}, function(err) { + if (err) return console.log('stream had an error or closed early'); + console.log('stream has ended but might still be writable'); +}); + +eos(duplexStream, {writable:false}, function(err) { + if (err) return console.log('stream had an error or closed early'); + console.log('stream has ended but might still be readable'); +}); + +eos(readableStream, {error:false}, function(err) { + // do not treat emit('error', err) as a end-of-stream +}); +``` + +## License + +MIT
\ No newline at end of file diff --git a/deps/npm/node_modules/mississippi/node_modules/duplexify/node_modules/end-of-stream/index.js b/deps/npm/node_modules/mississippi/node_modules/duplexify/node_modules/end-of-stream/index.js new file mode 100644 index 0000000000..9f61ed5af9 --- /dev/null +++ b/deps/npm/node_modules/mississippi/node_modules/duplexify/node_modules/end-of-stream/index.js @@ -0,0 +1,72 @@ +var once = require('once'); + +var noop = function() {}; + +var isRequest = function(stream) { + return stream.setHeader && typeof stream.abort === 'function'; +}; + +var eos = function(stream, opts, callback) { + if (typeof opts === 'function') return eos(stream, null, opts); + if (!opts) opts = {}; + + callback = once(callback || noop); + + var ws = stream._writableState; + var rs = stream._readableState; + var readable = opts.readable || (opts.readable !== false && stream.readable); + var writable = opts.writable || (opts.writable !== false && stream.writable); + + var onlegacyfinish = function() { + if (!stream.writable) onfinish(); + }; + + var onfinish = function() { + writable = false; + if (!readable) callback(); + }; + + var onend = function() { + readable = false; + if (!writable) callback(); + }; + + var onclose = function() { + if (readable && !(rs && rs.ended)) return callback(new Error('premature close')); + if (writable && !(ws && ws.ended)) return callback(new Error('premature close')); + }; + + var onrequest = function() { + stream.req.on('finish', onfinish); + }; + + if (isRequest(stream)) { + stream.on('complete', onfinish); + stream.on('abort', onclose); + if (stream.req) onrequest(); + else stream.on('request', onrequest); + } else if (writable && !ws) { // legacy streams + stream.on('end', onlegacyfinish); + stream.on('close', onlegacyfinish); + } + + stream.on('end', onend); + stream.on('finish', onfinish); + if (opts.error !== false) stream.on('error', callback); + stream.on('close', onclose); + + return function() { + stream.removeListener('complete', onfinish); + stream.removeListener('abort', onclose); + stream.removeListener('request', onrequest); + if (stream.req) stream.req.removeListener('finish', onfinish); + stream.removeListener('end', onlegacyfinish); + stream.removeListener('close', onlegacyfinish); + stream.removeListener('finish', onfinish); + stream.removeListener('end', onend); + stream.removeListener('error', callback); + stream.removeListener('close', onclose); + }; +}; + +module.exports = eos;
\ No newline at end of file diff --git a/deps/npm/node_modules/mississippi/node_modules/duplexify/node_modules/end-of-stream/node_modules/once/LICENSE b/deps/npm/node_modules/mississippi/node_modules/duplexify/node_modules/end-of-stream/node_modules/once/LICENSE new file mode 100644 index 0000000000..19129e315f --- /dev/null +++ b/deps/npm/node_modules/mississippi/node_modules/duplexify/node_modules/end-of-stream/node_modules/once/LICENSE @@ -0,0 +1,15 @@ +The ISC License + +Copyright (c) Isaac Z. Schlueter and Contributors + +Permission to use, copy, modify, and/or distribute this software for any +purpose with or without fee is hereby granted, provided that the above +copyright notice and this permission notice appear in all copies. + +THE SOFTWARE IS PROVIDED "AS IS" AND THE AUTHOR DISCLAIMS ALL WARRANTIES +WITH REGARD TO THIS SOFTWARE INCLUDING ALL IMPLIED WARRANTIES OF +MERCHANTABILITY AND FITNESS. IN NO EVENT SHALL THE AUTHOR BE LIABLE FOR +ANY SPECIAL, DIRECT, INDIRECT, OR CONSEQUENTIAL DAMAGES OR ANY DAMAGES +WHATSOEVER RESULTING FROM LOSS OF USE, DATA OR PROFITS, WHETHER IN AN +ACTION OF CONTRACT, NEGLIGENCE OR OTHER TORTIOUS ACTION, ARISING OUT OF OR +IN CONNECTION WITH THE USE OR PERFORMANCE OF THIS SOFTWARE. diff --git a/deps/npm/node_modules/mississippi/node_modules/duplexify/node_modules/end-of-stream/node_modules/once/README.md b/deps/npm/node_modules/mississippi/node_modules/duplexify/node_modules/end-of-stream/node_modules/once/README.md new file mode 100644 index 0000000000..a2981ea070 --- /dev/null +++ b/deps/npm/node_modules/mississippi/node_modules/duplexify/node_modules/end-of-stream/node_modules/once/README.md @@ -0,0 +1,51 @@ +# once + +Only call a function once. + +## usage + +```javascript +var once = require('once') + +function load (file, cb) { + cb = once(cb) + loader.load('file') + loader.once('load', cb) + loader.once('error', cb) +} +``` + +Or add to the Function.prototype in a responsible way: + +```javascript +// only has to be done once +require('once').proto() + +function load (file, cb) { + cb = cb.once() + loader.load('file') + loader.once('load', cb) + loader.once('error', cb) +} +``` + +Ironically, the prototype feature makes this module twice as +complicated as necessary. + +To check whether you function has been called, use `fn.called`. Once the +function is called for the first time the return value of the original +function is saved in `fn.value` and subsequent calls will continue to +return this value. + +```javascript +var once = require('once') + +function load (cb) { + cb = once(cb) + var stream = createStream() + stream.once('data', cb) + stream.once('end', function () { + if (!cb.called) cb(new Error('not found')) + }) +} +``` diff --git a/deps/npm/node_modules/mississippi/node_modules/duplexify/node_modules/end-of-stream/node_modules/once/once.js b/deps/npm/node_modules/mississippi/node_modules/duplexify/node_modules/end-of-stream/node_modules/once/once.js new file mode 100644 index 0000000000..2e1e721bfe --- /dev/null +++ b/deps/npm/node_modules/mississippi/node_modules/duplexify/node_modules/end-of-stream/node_modules/once/once.js @@ -0,0 +1,21 @@ +var wrappy = require('wrappy') +module.exports = wrappy(once) + +once.proto = once(function () { + Object.defineProperty(Function.prototype, 'once', { + value: function () { + return once(this) + }, + configurable: true + }) +}) + +function once (fn) { + var f = function () { + if (f.called) return f.value + f.called = true + return f.value = fn.apply(this, arguments) + } + f.called = false + return f +} diff --git a/deps/npm/node_modules/mississippi/node_modules/duplexify/node_modules/end-of-stream/node_modules/once/package.json b/deps/npm/node_modules/mississippi/node_modules/duplexify/node_modules/end-of-stream/node_modules/once/package.json new file mode 100644 index 0000000000..8c0e6e2991 --- /dev/null +++ b/deps/npm/node_modules/mississippi/node_modules/duplexify/node_modules/end-of-stream/node_modules/once/package.json @@ -0,0 +1,69 @@ +{ + "_from": "once@~1.3.0", + "_id": "once@1.3.3", + "_integrity": "sha1-suJhVXzkwxTsgwTz+oJmPkKXyiA=", + "_location": "/mississippi/duplexify/end-of-stream/once", + "_phantomChildren": {}, + "_requested": { + "type": "range", + "registry": true, + "raw": "once@~1.3.0", + "name": "once", + "escapedName": "once", + "rawSpec": "~1.3.0", + "saveSpec": null, + "fetchSpec": "~1.3.0" + }, + "_requiredBy": [ + "/mississippi/duplexify/end-of-stream" + ], + "_resolved": "https://registry.npmjs.org/once/-/once-1.3.3.tgz", + "_shasum": "b2e261557ce4c314ec8304f3fa82663e4297ca20", + "_shrinkwrap": null, + "_spec": "once@~1.3.0", + "_where": "/Users/zkat/Documents/code/npm/node_modules/mississippi/node_modules/duplexify/node_modules/end-of-stream", + "author": { + "name": "Isaac Z. Schlueter", + "email": "i@izs.me", + "url": "http://blog.izs.me/" + }, + "bin": null, + "bugs": { + "url": "https://github.com/isaacs/once/issues" + }, + "bundleDependencies": false, + "dependencies": { + "wrappy": "1" + }, + "deprecated": false, + "description": "Run a function exactly one time", + "devDependencies": { + "tap": "^1.2.0" + }, + "directories": { + "test": "test" + }, + "files": [ + "once.js" + ], + "homepage": "https://github.com/isaacs/once#readme", + "keywords": [ + "once", + "function", + "one", + "single" + ], + "license": "ISC", + "main": "once.js", + "name": "once", + "optionalDependencies": {}, + "peerDependencies": {}, + "repository": { + "type": "git", + "url": "git://github.com/isaacs/once.git" + }, + "scripts": { + "test": "tap test/*.js" + }, + "version": "1.3.3" +} diff --git a/deps/npm/node_modules/mississippi/node_modules/duplexify/node_modules/end-of-stream/package.json b/deps/npm/node_modules/mississippi/node_modules/duplexify/node_modules/end-of-stream/package.json new file mode 100644 index 0000000000..433faa2e6c --- /dev/null +++ b/deps/npm/node_modules/mississippi/node_modules/duplexify/node_modules/end-of-stream/package.json @@ -0,0 +1,65 @@ +{ + "_from": "end-of-stream@1.0.0", + "_id": "end-of-stream@1.0.0", + "_integrity": "sha1-1FlucCc0qT5A6a+GQxnqvZn/Lw4=", + "_location": "/mississippi/duplexify/end-of-stream", + "_phantomChildren": { + "wrappy": "1.0.2" + }, + "_requested": { + "type": "version", + "registry": true, + "raw": "end-of-stream@1.0.0", + "name": "end-of-stream", + "escapedName": "end-of-stream", + "rawSpec": "1.0.0", + "saveSpec": null, + "fetchSpec": "1.0.0" + }, + "_requiredBy": [ + "/mississippi/duplexify" + ], + "_resolved": "https://registry.npmjs.org/end-of-stream/-/end-of-stream-1.0.0.tgz", + "_shasum": "d4596e702734a93e40e9af864319eabd99ff2f0e", + "_shrinkwrap": null, + "_spec": "end-of-stream@1.0.0", + "_where": "/Users/zkat/Documents/code/npm/node_modules/mississippi/node_modules/duplexify", + "author": { + "name": "Mathias Buus", + "email": "mathiasbuus@gmail.com" + }, + "bin": null, + "bugs": { + "url": "https://github.com/mafintosh/end-of-stream/issues" + }, + "bundleDependencies": false, + "dependencies": { + "once": "~1.3.0" + }, + "deprecated": false, + "description": "Call a callback when a readable/writable/duplex stream has completed or failed.", + "devDependencies": {}, + "homepage": "https://github.com/mafintosh/end-of-stream", + "keywords": [ + "stream", + "streams", + "callback", + "finish", + "close", + "end", + "wait" + ], + "license": "MIT", + "main": "index.js", + "name": "end-of-stream", + "optionalDependencies": {}, + "peerDependencies": {}, + "repository": { + "type": "git", + "url": "git://github.com/mafintosh/end-of-stream.git" + }, + "scripts": { + "test": "node test.js" + }, + "version": "1.0.0" +} diff --git a/deps/npm/node_modules/mississippi/node_modules/duplexify/node_modules/end-of-stream/test.js b/deps/npm/node_modules/mississippi/node_modules/duplexify/node_modules/end-of-stream/test.js new file mode 100644 index 0000000000..d4d126fe56 --- /dev/null +++ b/deps/npm/node_modules/mississippi/node_modules/duplexify/node_modules/end-of-stream/test.js @@ -0,0 +1,62 @@ +var assert = require('assert'); +var eos = require('./index'); + +var expected = 6; +var fs = require('fs'); +var net = require('net'); + +var ws = fs.createWriteStream('/dev/null'); +eos(ws, function(err) { + expected--; + assert(!!err); + if (!expected) process.exit(0); +}); +ws.close(); + +var rs = fs.createReadStream('/dev/random'); +eos(rs, function(err) { + expected--; + assert(!!err); + if (!expected) process.exit(0); +}); +rs.close(); + +var rs = fs.createReadStream(__filename); +eos(rs, function(err) { + expected--; + assert(!err); + if (!expected) process.exit(0); +}); +rs.pipe(fs.createWriteStream('/dev/null')); + +var rs = fs.createReadStream(__filename); +eos(rs, function(err) { + throw new Error('no go') +})(); +rs.pipe(fs.createWriteStream('/dev/null')); + +var socket = net.connect(50000); +eos(socket, function(err) { + expected--; + assert(!!err); + if (!expected) process.exit(0); +}); + +var server = net.createServer(function(socket) { + eos(socket, function() { + expected--; + if (!expected) process.exit(0); + }); + socket.destroy(); +}).listen(30000, function() { + var socket = net.connect(30000); + eos(socket, function() { + expected--; + if (!expected) process.exit(0); + }); +}); + +setTimeout(function() { + assert(expected === 0); + process.exit(0); +}, 1000); diff --git a/deps/npm/node_modules/mississippi/node_modules/duplexify/package.json b/deps/npm/node_modules/mississippi/node_modules/duplexify/package.json index ed3ea4ab17..2249d135e5 100644 --- a/deps/npm/node_modules/mississippi/node_modules/duplexify/package.json +++ b/deps/npm/node_modules/mississippi/node_modules/duplexify/package.json @@ -1,10 +1,11 @@ { "_from": "duplexify@^3.4.2", - "_id": "duplexify@3.5.4", - "_inBundle": false, - "_integrity": "sha512-JzYSLYMhoVVBe8+mbHQ4KgpvHpm0DZpJuL8PY93Vyv1fW7jYJ90LoXa1di/CVbJM+TgMs91rbDapE/RNIfnJsA==", + "_id": "duplexify@3.5.0", + "_integrity": "sha1-GqdzAC4VeEV+nZ1KULDMquvL1gQ=", "_location": "/mississippi/duplexify", - "_phantomChildren": {}, + "_phantomChildren": { + "wrappy": "1.0.2" + }, "_requested": { "type": "range", "registry": true, @@ -19,19 +20,21 @@ "/mississippi", "/mississippi/pumpify" ], - "_resolved": "https://registry.npmjs.org/duplexify/-/duplexify-3.5.4.tgz", - "_shasum": "4bb46c1796eabebeec4ca9a2e66b808cb7a3d8b4", + "_resolved": "https://registry.npmjs.org/duplexify/-/duplexify-3.5.0.tgz", + "_shasum": "1aa773002e1578457e9d9d4a50b0ccaaebcbd604", + "_shrinkwrap": null, "_spec": "duplexify@^3.4.2", "_where": "/Users/zkat/Documents/code/npm/node_modules/mississippi", "author": { "name": "Mathias Buus" }, + "bin": null, "bugs": { "url": "https://github.com/mafintosh/duplexify/issues" }, "bundleDependencies": false, "dependencies": { - "end-of-stream": "^1.0.0", + "end-of-stream": "1.0.0", "inherits": "^2.0.1", "readable-stream": "^2.0.0", "stream-shift": "^1.0.0" @@ -39,9 +42,9 @@ "deprecated": false, "description": "Turn a writable and readable stream into a streams2 duplex stream with support for async initialization and streams1/streams2 input", "devDependencies": { - "concat-stream": "^1.5.2", - "tape": "^4.0.0", - "through2": "^2.0.0" + "concat-stream": "^1.4.6", + "tape": "^2.13.3", + "through2": "^0.5.1" }, "homepage": "https://github.com/mafintosh/duplexify", "keywords": [ @@ -56,6 +59,8 @@ "license": "MIT", "main": "index.js", "name": "duplexify", + "optionalDependencies": {}, + "peerDependencies": {}, "repository": { "type": "git", "url": "git://github.com/mafintosh/duplexify.git" @@ -63,5 +68,5 @@ "scripts": { "test": "tape test.js" }, - "version": "3.5.4" + "version": "3.5.0" } diff --git a/deps/npm/node_modules/mississippi/node_modules/duplexify/test.js b/deps/npm/node_modules/mississippi/node_modules/duplexify/test.js index 4330e93cf0..f4856d39ea 100644 --- a/deps/npm/node_modules/mississippi/node_modules/duplexify/test.js +++ b/deps/npm/node_modules/mississippi/node_modules/duplexify/test.js @@ -260,6 +260,7 @@ tape('prefinish not twice', function(t) { tape('close', function(t) { var passthrough = through() var dup = duplexify(passthrough, passthrough) + var ok = false passthrough.emit('close') dup.on('close', function() { diff --git a/deps/npm/node_modules/mississippi/node_modules/end-of-stream/index.js b/deps/npm/node_modules/mississippi/node_modules/end-of-stream/index.js index be426c227c..b3a9068634 100644 --- a/deps/npm/node_modules/mississippi/node_modules/end-of-stream/index.js +++ b/deps/npm/node_modules/mississippi/node_modules/end-of-stream/index.js @@ -39,10 +39,6 @@ var eos = function(stream, opts, callback) { callback.call(stream, exitCode ? new Error('exited with error code: ' + exitCode) : null); }; - var onerror = function(err) { - callback.call(stream, err); - }; - var onclose = function() { if (readable && !(rs && rs.ended)) return callback.call(stream, new Error('premature close')); if (writable && !(ws && ws.ended)) return callback.call(stream, new Error('premature close')); @@ -66,7 +62,7 @@ var eos = function(stream, opts, callback) { stream.on('end', onend); stream.on('finish', onfinish); - if (opts.error !== false) stream.on('error', onerror); + if (opts.error !== false) stream.on('error', callback); stream.on('close', onclose); return function() { @@ -79,7 +75,7 @@ var eos = function(stream, opts, callback) { stream.removeListener('finish', onfinish); stream.removeListener('exit', onexit); stream.removeListener('end', onend); - stream.removeListener('error', onerror); + stream.removeListener('error', callback); stream.removeListener('close', onclose); }; }; diff --git a/deps/npm/node_modules/mississippi/node_modules/end-of-stream/package.json b/deps/npm/node_modules/mississippi/node_modules/end-of-stream/package.json index 4af362d2b1..5610bee443 100644 --- a/deps/npm/node_modules/mississippi/node_modules/end-of-stream/package.json +++ b/deps/npm/node_modules/mississippi/node_modules/end-of-stream/package.json @@ -1,8 +1,7 @@ { "_from": "end-of-stream@^1.1.0", - "_id": "end-of-stream@1.4.1", - "_inBundle": false, - "_integrity": "sha512-1MkrZNvWTKCaigbn+W15elq2BB/L22nqrSY5DKlo3X6+vclJm8Bb5djXJBmEX6fS3+zCh/F4VBK5Z2KxJt4s2Q==", + "_id": "end-of-stream@1.4.0", + "_integrity": "sha1-epDYM+/abPpurA9JSduw+tOmMgY=", "_location": "/mississippi/end-of-stream", "_phantomChildren": {}, "_requested": { @@ -17,18 +16,19 @@ }, "_requiredBy": [ "/mississippi", - "/mississippi/duplexify", "/mississippi/pump", "/mississippi/stream-each" ], - "_resolved": "https://registry.npmjs.org/end-of-stream/-/end-of-stream-1.4.1.tgz", - "_shasum": "ed29634d19baba463b6ce6b80a37213eab71ec43", + "_resolved": "https://registry.npmjs.org/end-of-stream/-/end-of-stream-1.4.0.tgz", + "_shasum": "7a90d833efda6cfa6eac0f4949dbb0fad3a63206", + "_shrinkwrap": null, "_spec": "end-of-stream@^1.1.0", "_where": "/Users/zkat/Documents/code/npm/node_modules/mississippi", "author": { "name": "Mathias Buus", "email": "mathiasbuus@gmail.com" }, + "bin": null, "bugs": { "url": "https://github.com/mafintosh/end-of-stream/issues" }, @@ -38,6 +38,7 @@ }, "deprecated": false, "description": "Call a callback when a readable/writable/duplex stream has completed or failed.", + "devDependencies": {}, "files": [ "index.js" ], @@ -54,6 +55,8 @@ "license": "MIT", "main": "index.js", "name": "end-of-stream", + "optionalDependencies": {}, + "peerDependencies": {}, "repository": { "type": "git", "url": "git://github.com/mafintosh/end-of-stream.git" @@ -61,5 +64,5 @@ "scripts": { "test": "node test.js" }, - "version": "1.4.1" + "version": "1.4.0" } diff --git a/deps/npm/node_modules/mississippi/node_modules/pump/.npmignore b/deps/npm/node_modules/mississippi/node_modules/pump/.npmignore new file mode 100644 index 0000000000..3c3629e647 --- /dev/null +++ b/deps/npm/node_modules/mississippi/node_modules/pump/.npmignore @@ -0,0 +1 @@ +node_modules diff --git a/deps/npm/node_modules/mississippi/node_modules/pump/README.md b/deps/npm/node_modules/mississippi/node_modules/pump/README.md index 4c81471a0e..5029b27d68 100644 --- a/deps/npm/node_modules/mississippi/node_modules/pump/README.md +++ b/deps/npm/node_modules/mississippi/node_modules/pump/README.md @@ -47,15 +47,6 @@ pump(source, transform, anotherTransform, dest, function(err) { If `source`, `transform`, `anotherTransform` or `dest` closes all of them will be destroyed. -Similarly to `stream.pipe()`, `pump()` returns the last stream passed in, so you can do: - -``` -return pump(s1, s2) // returns s2 -``` - -If you want to return a stream that combines *both* s1 and s2 to a single stream use -[pumpify](https://github.com/mafintosh/pumpify) instead. - ## License MIT diff --git a/deps/npm/node_modules/mississippi/node_modules/pump/index.js b/deps/npm/node_modules/mississippi/node_modules/pump/index.js index c15059f176..060ce5f4fd 100644 --- a/deps/npm/node_modules/mississippi/node_modules/pump/index.js +++ b/deps/npm/node_modules/mississippi/node_modules/pump/index.js @@ -3,14 +3,12 @@ var eos = require('end-of-stream') var fs = require('fs') // we only need fs to get the ReadStream and WriteStream prototypes var noop = function () {} -var ancient = /^v?\.0/.test(process.version) var isFn = function (fn) { return typeof fn === 'function' } var isFS = function (stream) { - if (!ancient) return false // newer node version do not need to care about fs is a special way if (!fs) return false // browser return (stream instanceof (fs.ReadStream || noop) || stream instanceof (fs.WriteStream || noop)) && isFn(stream.close) } @@ -39,7 +37,7 @@ var destroyer = function (stream, reading, writing, callback) { if (destroyed) return destroyed = true - if (isFS(stream)) return stream.close(noop) // use close for fs streams to avoid fd leaks + if (isFS(stream)) return stream.close() // use close for fs streams to avoid fd leaks if (isRequest(stream)) return stream.abort() // request.destroy just do .end - .abort is what we want if (isFn(stream.destroy)) return stream.destroy() diff --git a/deps/npm/node_modules/mississippi/node_modules/pump/package.json b/deps/npm/node_modules/mississippi/node_modules/pump/package.json index 6e62ee06cd..2ec8b797bc 100644 --- a/deps/npm/node_modules/mississippi/node_modules/pump/package.json +++ b/deps/npm/node_modules/mississippi/node_modules/pump/package.json @@ -1,31 +1,33 @@ { - "_from": "pump@^3.0.0", - "_id": "pump@3.0.0", - "_inBundle": false, - "_integrity": "sha512-LwZy+p3SFs1Pytd/jYct4wpv49HiYCqd9Rlc5ZVdk0V+8Yzv6jR5Blk3TRmPL1ft69TxP0IMZGJ+WPFU2BFhww==", + "_from": "pump@^1.0.0", + "_id": "pump@1.0.2", + "_integrity": "sha1-Oz7mUS+U8OV1U4wXmV+fFpkKXVE=", "_location": "/mississippi/pump", "_phantomChildren": {}, "_requested": { "type": "range", "registry": true, - "raw": "pump@^3.0.0", + "raw": "pump@^1.0.0", "name": "pump", "escapedName": "pump", - "rawSpec": "^3.0.0", + "rawSpec": "^1.0.0", "saveSpec": null, - "fetchSpec": "^3.0.0" + "fetchSpec": "^1.0.0" }, "_requiredBy": [ - "/mississippi" + "/mississippi", + "/mississippi/pumpify" ], - "_resolved": "https://registry.npmjs.org/pump/-/pump-3.0.0.tgz", - "_shasum": "b4a2116815bde2f4e1ea602354e8c75565107a64", - "_spec": "pump@^3.0.0", + "_resolved": "https://registry.npmjs.org/pump/-/pump-1.0.2.tgz", + "_shasum": "3b3ee6512f94f0e575538c17995f9f16990a5d51", + "_shrinkwrap": null, + "_spec": "pump@^1.0.0", "_where": "/Users/zkat/Documents/code/npm/node_modules/mississippi", "author": { "name": "Mathias Buus Madsen", "email": "mathiasbuus@gmail.com" }, + "bin": null, "browser": { "fs": false }, @@ -39,6 +41,7 @@ }, "deprecated": false, "description": "pipe streams together and close all of them if one of them closes", + "devDependencies": {}, "homepage": "https://github.com/mafintosh/pump#readme", "keywords": [ "streams", @@ -48,12 +51,14 @@ ], "license": "MIT", "name": "pump", + "optionalDependencies": {}, + "peerDependencies": {}, "repository": { "type": "git", "url": "git://github.com/mafintosh/pump.git" }, "scripts": { - "test": "node test-browser.js && node test-node.js" + "test": "node test.js" }, - "version": "3.0.0" + "version": "1.0.2" } diff --git a/deps/npm/node_modules/mississippi/node_modules/pump/test-browser.js b/deps/npm/node_modules/mississippi/node_modules/pump/test-browser.js index 9a06c8a4cc..80e852c7dc 100644 --- a/deps/npm/node_modules/mississippi/node_modules/pump/test-browser.js +++ b/deps/npm/node_modules/mississippi/node_modules/pump/test-browser.js @@ -30,10 +30,7 @@ var rsClosed = false var callbackCalled = false var check = function () { - if (wsClosed && rsClosed && callbackCalled) { - console.log('test-browser.js passes') - clearTimeout(timeout) - } + if (wsClosed && rsClosed && callbackCalled) console.log('done') } ws.on('finish', function () { @@ -46,21 +43,16 @@ rs.on('end', function () { check() }) -var res = pump(rs, toHex(), toHex(), toHex(), ws, function () { +pump(rs, toHex(), toHex(), toHex(), ws, function () { callbackCalled = true check() }) -if (res !== ws) { - throw new Error('should return last stream') -} - setTimeout(function () { rs.push(null) rs.emit('close') }, 1000) -var timeout = setTimeout(function () { - check() - throw new Error('timeout') +setTimeout(function () { + if (!check()) throw new Error('timeout') }, 5000) diff --git a/deps/npm/node_modules/mississippi/node_modules/pump/test-node.js b/deps/npm/node_modules/mississippi/node_modules/pump/test-node.js deleted file mode 100644 index 561251a082..0000000000 --- a/deps/npm/node_modules/mississippi/node_modules/pump/test-node.js +++ /dev/null @@ -1,53 +0,0 @@ -var pump = require('./index') - -var rs = require('fs').createReadStream('/dev/random') -var ws = require('fs').createWriteStream('/dev/null') - -var toHex = function () { - var reverse = new (require('stream').Transform)() - - reverse._transform = function (chunk, enc, callback) { - reverse.push(chunk.toString('hex')) - callback() - } - - return reverse -} - -var wsClosed = false -var rsClosed = false -var callbackCalled = false - -var check = function () { - if (wsClosed && rsClosed && callbackCalled) { - console.log('test-node.js passes') - clearTimeout(timeout) - } -} - -ws.on('close', function () { - wsClosed = true - check() -}) - -rs.on('close', function () { - rsClosed = true - check() -}) - -var res = pump(rs, toHex(), toHex(), toHex(), ws, function () { - callbackCalled = true - check() -}) - -if (res !== ws) { - throw new Error('should return last stream') -} - -setTimeout(function () { - rs.destroy() -}, 1000) - -var timeout = setTimeout(function () { - throw new Error('timeout') -}, 5000) diff --git a/deps/npm/node_modules/mississippi/node_modules/pumpify/node_modules/pump/test-node.js b/deps/npm/node_modules/mississippi/node_modules/pump/test.js index 034a65414d..64e772ca5b 100644 --- a/deps/npm/node_modules/mississippi/node_modules/pumpify/node_modules/pump/test-node.js +++ b/deps/npm/node_modules/mississippi/node_modules/pump/test.js @@ -19,10 +19,7 @@ var rsClosed = false var callbackCalled = false var check = function () { - if (wsClosed && rsClosed && callbackCalled) { - console.log('test-node.js passes') - clearTimeout(timeout) - } + if (wsClosed && rsClosed && callbackCalled) process.exit(0) } ws.on('close', function () { @@ -35,19 +32,15 @@ rs.on('close', function () { check() }) -var res = pump(rs, toHex(), toHex(), toHex(), ws, function () { +pump(rs, toHex(), toHex(), toHex(), ws, function () { callbackCalled = true check() }) -if (res) { - process.exit(1) -} - setTimeout(function () { rs.destroy() }, 1000) -var timeout = setTimeout(function () { +setTimeout(function () { throw new Error('timeout') }, 5000) diff --git a/deps/npm/node_modules/mississippi/node_modules/pumpify/.npmignore b/deps/npm/node_modules/mississippi/node_modules/pumpify/.npmignore new file mode 100644 index 0000000000..3c3629e647 --- /dev/null +++ b/deps/npm/node_modules/mississippi/node_modules/pumpify/.npmignore @@ -0,0 +1 @@ +node_modules diff --git a/deps/npm/node_modules/mississippi/node_modules/pumpify/index.js b/deps/npm/node_modules/mississippi/node_modules/pumpify/index.js index 45bb987e85..147de675c3 100644 --- a/deps/npm/node_modules/mississippi/node_modules/pumpify/index.js +++ b/deps/npm/node_modules/mississippi/node_modules/pumpify/index.js @@ -53,4 +53,3 @@ var define = function(opts) { module.exports = define({destroy:false}) module.exports.obj = define({destroy:false, objectMode:true, highWaterMark:16}) -module.exports.ctor = define diff --git a/deps/npm/node_modules/mississippi/node_modules/pumpify/node_modules/pump/.travis.yml b/deps/npm/node_modules/mississippi/node_modules/pumpify/node_modules/pump/.travis.yml deleted file mode 100644 index 17f94330e7..0000000000 --- a/deps/npm/node_modules/mississippi/node_modules/pumpify/node_modules/pump/.travis.yml +++ /dev/null @@ -1,5 +0,0 @@ -language: node_js -node_js: - - "0.10" - -script: "npm test" diff --git a/deps/npm/node_modules/mississippi/node_modules/pumpify/node_modules/pump/LICENSE b/deps/npm/node_modules/mississippi/node_modules/pumpify/node_modules/pump/LICENSE deleted file mode 100644 index 757562ec59..0000000000 --- a/deps/npm/node_modules/mississippi/node_modules/pumpify/node_modules/pump/LICENSE +++ /dev/null @@ -1,21 +0,0 @@ -The MIT License (MIT) - -Copyright (c) 2014 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.
\ No newline at end of file diff --git a/deps/npm/node_modules/mississippi/node_modules/pumpify/node_modules/pump/README.md b/deps/npm/node_modules/mississippi/node_modules/pumpify/node_modules/pump/README.md deleted file mode 100644 index 5029b27d68..0000000000 --- a/deps/npm/node_modules/mississippi/node_modules/pumpify/node_modules/pump/README.md +++ /dev/null @@ -1,56 +0,0 @@ -# pump - -pump is a small node module that pipes streams together and destroys all of them if one of them closes. - -``` -npm install pump -``` - -[](http://travis-ci.org/mafintosh/pump) - -## What problem does it solve? - -When using standard `source.pipe(dest)` source will _not_ be destroyed if dest emits close or an error. -You are also not able to provide a callback to tell when then pipe has finished. - -pump does these two things for you - -## Usage - -Simply pass the streams you want to pipe together to pump and add an optional callback - -``` js -var pump = require('pump') -var fs = require('fs') - -var source = fs.createReadStream('/dev/random') -var dest = fs.createWriteStream('/dev/null') - -pump(source, dest, function(err) { - console.log('pipe finished', err) -}) - -setTimeout(function() { - dest.destroy() // when dest is closed pump will destroy source -}, 1000) -``` - -You can use pump to pipe more than two streams together as well - -``` js -var transform = someTransformStream() - -pump(source, transform, anotherTransform, dest, function(err) { - console.log('pipe finished', err) -}) -``` - -If `source`, `transform`, `anotherTransform` or `dest` closes all of them will be destroyed. - -## License - -MIT - -## Related - -`pump` 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/deps/npm/node_modules/mississippi/node_modules/pumpify/node_modules/pump/index.js b/deps/npm/node_modules/mississippi/node_modules/pumpify/node_modules/pump/index.js deleted file mode 100644 index d9ca0335cb..0000000000 --- a/deps/npm/node_modules/mississippi/node_modules/pumpify/node_modules/pump/index.js +++ /dev/null @@ -1,82 +0,0 @@ -var once = require('once') -var eos = require('end-of-stream') -var fs = require('fs') // we only need fs to get the ReadStream and WriteStream prototypes - -var noop = function () {} -var ancient = /^v?\.0/.test(process.version) - -var isFn = function (fn) { - return typeof fn === 'function' -} - -var isFS = function (stream) { - if (!ancient) return false // newer node version do not need to care about fs is a special way - if (!fs) return false // browser - return (stream instanceof (fs.ReadStream || noop) || stream instanceof (fs.WriteStream || noop)) && isFn(stream.close) -} - -var isRequest = function (stream) { - return stream.setHeader && isFn(stream.abort) -} - -var destroyer = function (stream, reading, writing, callback) { - callback = once(callback) - - var closed = false - stream.on('close', function () { - closed = true - }) - - eos(stream, {readable: reading, writable: writing}, function (err) { - if (err) return callback(err) - closed = true - callback() - }) - - var destroyed = false - return function (err) { - if (closed) return - if (destroyed) return - destroyed = true - - if (isFS(stream)) return stream.close(noop) // use close for fs streams to avoid fd leaks - if (isRequest(stream)) return stream.abort() // request.destroy just do .end - .abort is what we want - - if (isFn(stream.destroy)) return stream.destroy() - - callback(err || new Error('stream was destroyed')) - } -} - -var call = function (fn) { - fn() -} - -var pipe = function (from, to) { - return from.pipe(to) -} - -var pump = function () { - var streams = Array.prototype.slice.call(arguments) - var callback = isFn(streams[streams.length - 1] || noop) && streams.pop() || noop - - if (Array.isArray(streams[0])) streams = streams[0] - if (streams.length < 2) throw new Error('pump requires two streams per minimum') - - var error - var destroys = streams.map(function (stream, i) { - var reading = i < streams.length - 1 - var writing = i > 0 - return destroyer(stream, reading, writing, function (err) { - if (!error) error = err - if (err) destroys.forEach(call) - if (reading) return - destroys.forEach(call) - callback(error) - }) - }) - - streams.reduce(pipe) -} - -module.exports = pump diff --git a/deps/npm/node_modules/mississippi/node_modules/pumpify/node_modules/pump/package.json b/deps/npm/node_modules/mississippi/node_modules/pumpify/node_modules/pump/package.json deleted file mode 100644 index ebd36d7415..0000000000 --- a/deps/npm/node_modules/mississippi/node_modules/pumpify/node_modules/pump/package.json +++ /dev/null @@ -1,59 +0,0 @@ -{ - "_from": "pump@^2.0.0", - "_id": "pump@2.0.1", - "_inBundle": false, - "_integrity": "sha512-ruPMNRkN3MHP1cWJc9OWr+T/xDP0jhXYCLfJcBuX54hhfIBnaQmAUMfDcG4DM5UMWByBbJY69QSphm3jtDKIkA==", - "_location": "/mississippi/pumpify/pump", - "_phantomChildren": {}, - "_requested": { - "type": "range", - "registry": true, - "raw": "pump@^2.0.0", - "name": "pump", - "escapedName": "pump", - "rawSpec": "^2.0.0", - "saveSpec": null, - "fetchSpec": "^2.0.0" - }, - "_requiredBy": [ - "/mississippi/pumpify" - ], - "_resolved": "https://registry.npmjs.org/pump/-/pump-2.0.1.tgz", - "_shasum": "12399add6e4cf7526d973cbc8b5ce2e2908b3909", - "_spec": "pump@^2.0.0", - "_where": "/Users/zkat/Documents/code/npm/node_modules/mississippi/node_modules/pumpify", - "author": { - "name": "Mathias Buus Madsen", - "email": "mathiasbuus@gmail.com" - }, - "browser": { - "fs": false - }, - "bugs": { - "url": "https://github.com/mafintosh/pump/issues" - }, - "bundleDependencies": false, - "dependencies": { - "end-of-stream": "^1.1.0", - "once": "^1.3.1" - }, - "deprecated": false, - "description": "pipe streams together and close all of them if one of them closes", - "homepage": "https://github.com/mafintosh/pump#readme", - "keywords": [ - "streams", - "pipe", - "destroy", - "callback" - ], - "license": "MIT", - "name": "pump", - "repository": { - "type": "git", - "url": "git://github.com/mafintosh/pump.git" - }, - "scripts": { - "test": "node test-browser.js && node test-node.js" - }, - "version": "2.0.1" -} diff --git a/deps/npm/node_modules/mississippi/node_modules/pumpify/node_modules/pump/test-browser.js b/deps/npm/node_modules/mississippi/node_modules/pumpify/node_modules/pump/test-browser.js deleted file mode 100644 index 75ea4a292e..0000000000 --- a/deps/npm/node_modules/mississippi/node_modules/pumpify/node_modules/pump/test-browser.js +++ /dev/null @@ -1,62 +0,0 @@ -var stream = require('stream') -var pump = require('./index') - -var rs = new stream.Readable() -var ws = new stream.Writable() - -rs._read = function (size) { - this.push(Buffer(size).fill('abc')) -} - -ws._write = function (chunk, encoding, cb) { - setTimeout(function () { - cb() - }, 100) -} - -var toHex = function () { - var reverse = new (require('stream').Transform)() - - reverse._transform = function (chunk, enc, callback) { - reverse.push(chunk.toString('hex')) - callback() - } - - return reverse -} - -var wsClosed = false -var rsClosed = false -var callbackCalled = false - -var check = function () { - if (wsClosed && rsClosed && callbackCalled) { - console.log('test-browser.js passes') - clearTimeout(timeout) - } -} - -ws.on('finish', function () { - wsClosed = true - check() -}) - -rs.on('end', function () { - rsClosed = true - check() -}) - -pump(rs, toHex(), toHex(), toHex(), ws, function () { - callbackCalled = true - check() -}) - -setTimeout(function () { - rs.push(null) - rs.emit('close') -}, 1000) - -var timeout = setTimeout(function () { - check() - throw new Error('timeout') -}, 5000) diff --git a/deps/npm/node_modules/mississippi/node_modules/pumpify/package.json b/deps/npm/node_modules/mississippi/node_modules/pumpify/package.json index f2be43f0b9..8bb5cbd0c9 100644 --- a/deps/npm/node_modules/mississippi/node_modules/pumpify/package.json +++ b/deps/npm/node_modules/mississippi/node_modules/pumpify/package.json @@ -1,8 +1,7 @@ { "_from": "pumpify@^1.3.3", - "_id": "pumpify@1.4.0", - "_inBundle": false, - "_integrity": "sha512-2kmNR9ry+Pf45opRVirpNuIFotsxUGLaYqxIwuR77AYrYRMuFCz9eryHBS52L360O+NcR383CL4QYlMKPq4zYA==", + "_id": "pumpify@1.3.5", + "_integrity": "sha1-G2ccYZlAq8rqwK0OOjwWS+dgmTs=", "_location": "/mississippi/pumpify", "_phantomChildren": {}, "_requested": { @@ -18,27 +17,29 @@ "_requiredBy": [ "/mississippi" ], - "_resolved": "https://registry.npmjs.org/pumpify/-/pumpify-1.4.0.tgz", - "_shasum": "80b7c5df7e24153d03f0e7ac8a05a5d068bd07fb", + "_resolved": "https://registry.npmjs.org/pumpify/-/pumpify-1.3.5.tgz", + "_shasum": "1b671c619940abcaeac0ad0e3a3c164be760993b", + "_shrinkwrap": null, "_spec": "pumpify@^1.3.3", "_where": "/Users/zkat/Documents/code/npm/node_modules/mississippi", "author": { "name": "Mathias Buus" }, + "bin": null, "bugs": { "url": "https://github.com/mafintosh/pumpify/issues" }, "bundleDependencies": false, "dependencies": { - "duplexify": "^3.5.3", - "inherits": "^2.0.3", - "pump": "^2.0.0" + "duplexify": "^3.1.2", + "inherits": "^2.0.1", + "pump": "^1.0.0" }, "deprecated": false, "description": "Combine an array of streams into a single duplex stream using pump and duplexify", "devDependencies": { - "tape": "^4.8.0", - "through2": "^2.0.3" + "tape": "^2.13.3", + "through2": "^0.5.1" }, "homepage": "https://github.com/mafintosh/pumpify", "keywords": [ @@ -53,6 +54,8 @@ "license": "MIT", "main": "index.js", "name": "pumpify", + "optionalDependencies": {}, + "peerDependencies": {}, "repository": { "type": "git", "url": "git://github.com/mafintosh/pumpify.git" @@ -60,5 +63,5 @@ "scripts": { "test": "tape test.js" }, - "version": "1.4.0" + "version": "1.3.5" } diff --git a/deps/npm/node_modules/mississippi/node_modules/pumpify/test.js b/deps/npm/node_modules/mississippi/node_modules/pumpify/test.js index de6b16e346..4ee91c5f3e 100644 --- a/deps/npm/node_modules/mississippi/node_modules/pumpify/test.js +++ b/deps/npm/node_modules/mississippi/node_modules/pumpify/test.js @@ -160,22 +160,4 @@ tape('early destroy', function(t) { setTimeout(function() { pipeline.setPipeline(a, b, c) }, 100) -}) - -tape('preserves error', function (t) { - var a = through() - var b = through(function (data, enc, cb) { - cb(new Error('stop')) - }) - var c = through() - var s = pumpify() - - s.on('error', function (err) { - t.same(err.message, 'stop') - t.end() - }) - - s.setPipeline(a, b, c) - s.resume() - s.write('hi') -}) +})
\ No newline at end of file diff --git a/deps/npm/node_modules/mississippi/node_modules/stream-each/index.js b/deps/npm/node_modules/mississippi/node_modules/stream-each/index.js index 7e67f7337a..2c07e957a3 100644 --- a/deps/npm/node_modules/mississippi/node_modules/stream-each/index.js +++ b/deps/npm/node_modules/mississippi/node_modules/stream-each/index.js @@ -8,7 +8,6 @@ function each (stream, fn, cb) { var error = null var ended = false var running = false - var calling = false stream.on('readable', onreadable) onreadable() @@ -36,23 +35,20 @@ function each (stream, fn, cb) { return } if (ended) return cb(error) - if (!calling) read() + read() } function read () { - while (!running && !ended) { - want = false - - var data = shift(stream) - if (data === null) { - want = true - return - } - - running = true - calling = true - fn(data, afterRead) - calling = false + if (ended || running) return + want = false + + var data = shift(stream) + if (!data) { + want = true + return } + + running = true + fn(data, afterRead) } } diff --git a/deps/npm/node_modules/mississippi/node_modules/stream-each/package.json b/deps/npm/node_modules/mississippi/node_modules/stream-each/package.json index 49b4df18e1..39f4cd01f4 100644 --- a/deps/npm/node_modules/mississippi/node_modules/stream-each/package.json +++ b/deps/npm/node_modules/mississippi/node_modules/stream-each/package.json @@ -1,8 +1,7 @@ { "_from": "stream-each@^1.1.0", - "_id": "stream-each@1.2.2", - "_inBundle": false, - "_integrity": "sha512-mc1dbFhGBxvTM3bIWmAAINbqiuAk9TATcfIQC8P+/+HJefgaiTlMn2dHvkX8qlI12KeYKSQ1Ua9RrIqrn1VPoA==", + "_id": "stream-each@1.2.0", + "_integrity": "sha1-HpXUdXP1gNgU3A/4zQ9m8c5TyZE=", "_location": "/mississippi/stream-each", "_phantomChildren": {}, "_requested": { @@ -18,14 +17,16 @@ "_requiredBy": [ "/mississippi" ], - "_resolved": "https://registry.npmjs.org/stream-each/-/stream-each-1.2.2.tgz", - "_shasum": "8e8c463f91da8991778765873fe4d960d8f616bd", + "_resolved": "https://registry.npmjs.org/stream-each/-/stream-each-1.2.0.tgz", + "_shasum": "1e95d47573f580d814dc0ff8cd0f66f1ce53c991", + "_shrinkwrap": null, "_spec": "stream-each@^1.1.0", "_where": "/Users/zkat/Documents/code/npm/node_modules/mississippi", "author": { "name": "Mathias Buus", "url": "@mafintosh" }, + "bin": null, "bugs": { "url": "https://github.com/mafintosh/stream-each/issues" }, @@ -45,6 +46,8 @@ "license": "MIT", "main": "index.js", "name": "stream-each", + "optionalDependencies": {}, + "peerDependencies": {}, "repository": { "type": "git", "url": "git+https://github.com/mafintosh/stream-each.git" @@ -52,5 +55,5 @@ "scripts": { "test": "standard && tape test.js" }, - "version": "1.2.2" + "version": "1.2.0" } 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 277634cd05..36454c45eb 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,43 +80,3 @@ 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() - }) -}) diff --git a/deps/npm/node_modules/mississippi/package.json b/deps/npm/node_modules/mississippi/package.json index 7cb47a7cd5..1e6d2ab81f 100644 --- a/deps/npm/node_modules/mississippi/package.json +++ b/deps/npm/node_modules/mississippi/package.json @@ -1,35 +1,39 @@ { - "_from": "mississippi@3.0.0", - "_id": "mississippi@3.0.0", - "_inBundle": false, - "_integrity": "sha512-x471SsVjUtBRtcvd4BzKE9kFC+/2TeWgKCgw0bZcw1b9l2X3QX5vCWgF+KaZaYm87Ss//rHnWryupDrgLvmSkA==", + "_from": "mississippi@~1.3.0", + "_id": "mississippi@1.3.0", + "_integrity": "sha1-0gFYPrEjJ+PFwWQqQEqcrPlONPU=", "_location": "/mississippi", "_phantomChildren": { "inherits": "2.0.3", "once": "1.4.0", - "readable-stream": "2.3.5" + "readable-stream": "2.2.9", + "wrappy": "1.0.2" }, "_requested": { - "type": "version", + "type": "range", "registry": true, - "raw": "mississippi@3.0.0", + "raw": "mississippi@~1.3.0", "name": "mississippi", "escapedName": "mississippi", - "rawSpec": "3.0.0", + "rawSpec": "~1.3.0", "saveSpec": null, - "fetchSpec": "3.0.0" + "fetchSpec": "~1.3.0" }, "_requiredBy": [ - "#USER", - "/" + "/", + "/cacache", + "/pacote", + "/pacote/make-fetch-happen" ], - "_resolved": "https://registry.npmjs.org/mississippi/-/mississippi-3.0.0.tgz", - "_shasum": "ea0a3291f97e0b5e8776b363d5f0a12d94c67022", - "_spec": "mississippi@3.0.0", + "_resolved": "https://registry.npmjs.org/mississippi/-/mississippi-1.3.0.tgz", + "_shasum": "d201583eb12327e3c5c1642a404a9cacf94e34f5", + "_shrinkwrap": null, + "_spec": "mississippi@~1.3.0", "_where": "/Users/zkat/Documents/code/npm", "author": { "name": "max ogden" }, + "bin": null, "bugs": { "url": "https://github.com/maxogden/mississippi/issues" }, @@ -41,7 +45,7 @@ "flush-write-stream": "^1.0.0", "from2": "^2.1.0", "parallel-transform": "^1.1.0", - "pump": "^3.0.0", + "pump": "^1.0.0", "pumpify": "^1.3.3", "stream-each": "^1.1.0", "through2": "^2.0.0" @@ -49,13 +53,12 @@ "deprecated": false, "description": "a collection of useful streams", "devDependencies": {}, - "engines": { - "node": ">=4.0.0" - }, "homepage": "https://github.com/maxogden/mississippi#readme", "license": "BSD-2-Clause", "main": "index.js", "name": "mississippi", + "optionalDependencies": {}, + "peerDependencies": {}, "repository": { "type": "git", "url": "git+https://github.com/maxogden/mississippi.git" @@ -63,5 +66,5 @@ "scripts": { "test": "echo \"Error: no test specified\" && exit 1" }, - "version": "3.0.0" + "version": "1.3.0" } diff --git a/deps/npm/node_modules/mississippi/readme.md b/deps/npm/node_modules/mississippi/readme.md index 5fa6d66c89..569803865c 100644 --- a/deps/npm/node_modules/mississippi/readme.md +++ b/deps/npm/node_modules/mississippi/readme.md @@ -74,7 +74,7 @@ var split = require('split2') var newLineSeparatedNumbers = fs.createReadStream('numbers.txt') var pipeline = miss.pipeline(newLineSeparatedNumbers, split()) -miss.each(pipeline, eachLine, done) +var each = miss.each(pipeline, eachLine, done) var sum = 0 function eachLine (line, next) { @@ -94,8 +94,6 @@ function done (err) { Builds a pipeline from all the transform streams passed in as arguments by piping them together and returning a single stream object that lets you write to the first stream and read from the last stream. -If you are pumping object streams together use `pipeline = miss.pipeline.obj(s1, s2, ...)`. - If any of the streams in the pipeline emits an error or gets destroyed, or you destroy the stream it returns, all of the streams will be destroyed and cleaned up for you. #### original module @@ -156,7 +154,7 @@ var duplexCurl = miss.duplex(curl.stdin, curl.stdout) ### through -##### `var transformer = miss.through([options, transformFunction, flushFunction])` +#####`var transformer = miss.through([options, transformFunction, flushFunction])` Make a custom [transform stream](https://nodejs.org/docs/latest/api/stream.html#stream_class_stream_transform). @@ -196,7 +194,7 @@ miss.pipe(read, uppercaser, write, function (err) { ### from -##### `miss.from([opts], read)` +#####`miss.from([opts], read)` Make a custom [readable stream](https://nodejs.org/docs/latest/api/stream.html#stream_class_stream_readable). @@ -239,17 +237,17 @@ fromString('hello world').pipe(process.stdout) ### to -##### `miss.to([options], write, [flush])` +#####`miss.to([options], write, [flush])` Make a custom [writable stream](https://nodejs.org/docs/latest/api/stream.html#stream_class_stream_writable). -`opts` contains the options to pass on to the WritableStream constructor e.g. for creating a writable object stream (or use the shortcut `miss.to.obj([...])`). +`opts` contains the options to pass on to the WritableStream constructor e.g. for creating a readable object stream (or use the shortcut `miss.to.obj([...])`). Returns a writable stream that calls `write(data, enc, cb)` when data is written to the stream. - `data` is the received data to write the destination. - `enc` encoding of the piece of data received. -- `cb(err, data)` should be called when you're ready to write more data, or encountered an error. +- `next(err, chunk)` should be called when you're ready to write more data, or encountered an error. `flush(cb)` is called before `finish` is emitted and allows for cleanup steps to occur. @@ -293,7 +291,7 @@ finished ### concat -##### `var concat = miss.concat(cb)` +#####`var concat = miss.concat(cb)` Returns a writable stream that concatenates all data written to the stream and calls a callback with the single result. @@ -309,18 +307,13 @@ Note that `miss.concat` will not handle stream errors for you. To handle errors, ```js var fs = require('fs') +var concat = require('concat-stream') var readStream = fs.createReadStream('cat.png') -var concatStream = miss.concat(gotPicture) - -function callback (err) { - if (err) { - console.error(err) - process.exit(1) - } -} +var concatStream = concat(gotPicture) -miss.pipe(readStream, concatStream, callback) +readStream.on('error', handleError) +readStream.pipe(concatStream) function gotPicture(imageBuffer) { // imageBuffer is all of `cat.png` as a node.js Buffer @@ -335,7 +328,7 @@ function handleError(err) { ### finished -##### `miss.finished(stream, cb)` +#####`miss.finished(stream, cb)` Waits for `stream` to finish or error and then calls `cb` with `(err)`. `cb` will only be called once. `err` will be null if the stream finished without error, or else it will be populated with the error from the streams `error` event. @@ -361,7 +354,7 @@ miss.finished(copyDest, function(err) { ### parallel -##### `miss.parallel(concurrency, each)` +#####`miss.parallel(concurrency, each)` This works like `through` except you can process items in parallel, while still preserving the original input order. @@ -399,13 +392,3 @@ miss.pipe( }) ) ``` - -## see also - -- [substack/stream-handbook](https://github.com/substack/stream-handbook) -- [nodejs.org/api/stream.html](https://nodejs.org/api/stream.html) -- [awesome-nodejs-streams](https://github.com/thejmazz/awesome-nodejs-streams) - -## license - -Licensed under the BSD 2-clause license. |