summaryrefslogtreecommitdiff
path: root/deps/node/deps/npm/node_modules/sorted-union-stream/node_modules/from2/index.js
diff options
context:
space:
mode:
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.js93
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
-}