diff options
Diffstat (limited to 'deps/node/deps/npm/node_modules/sorted-union-stream/node_modules/from2/index.js')
-rw-r--r-- | deps/node/deps/npm/node_modules/sorted-union-stream/node_modules/from2/index.js | 93 |
1 files changed, 0 insertions, 93 deletions
diff --git a/deps/node/deps/npm/node_modules/sorted-union-stream/node_modules/from2/index.js b/deps/node/deps/npm/node_modules/sorted-union-stream/node_modules/from2/index.js deleted file mode 100644 index d83be0b5..00000000 --- a/deps/node/deps/npm/node_modules/sorted-union-stream/node_modules/from2/index.js +++ /dev/null @@ -1,93 +0,0 @@ -var Readable = require('readable-stream').Readable -var inherits = require('inherits') - -module.exports = from2 - -from2.ctor = ctor -from2.obj = obj - -var Proto = ctor() - -function toFunction(list) { - list = list.slice() - return function (_, cb) { - cb(null, list.length ? list.shift() : null) - } -} - -function from2(opts, read) { - if (typeof opts !== 'object' || Array.isArray(opts)) { - read = opts - opts = {} - } - - if (Array.isArray(read)) read = toFunction(read) - - var rs = new Proto(opts) - rs._from = read - return rs -} - -function ctor(opts, read) { - if (typeof opts === 'function') { - read = opts - opts = {} - } - - opts = defaults(opts) - - inherits(Class, Readable) - function Class(override) { - if (!(this instanceof Class)) return new Class(override) - this._reading = false - this.destroyed = false - Readable.call(this, override || opts) - } - - Class.prototype._from = read - Class.prototype._read = function(size) { - var self = this - - if (this._reading || this.destroyed) return - this._reading = true - this._from(size, check) - function check(err, data) { - if (self.destroyed) return - if (err) return self.destroy(err) - if (data === null) return self.push(null) - self._reading = false - if (self.push(data)) self._read() - } - } - - Class.prototype.destroy = function(err) { - if (this.destroyed) return - this.destroyed = true - - var self = this - process.nextTick(function() { - if (err) self.emit('error', err) - self.emit('close') - }) - } - - return Class -} - -function obj(opts, read) { - if (typeof opts === 'function' || Array.isArray(opts)) { - read = opts - opts = {} - } - - opts = defaults(opts) - opts.objectMode = true - opts.highWaterMark = 16 - - return from2(opts, read) -} - -function defaults(opts) { - opts = opts || {} - return opts -} |