#$@%#$%!

Ngiler SH3LL 360
: / lib / node_modules / npm / node_modules / from2 /

Information Server
MySQL : OFF Perl : OFF CURL : ON WGET : OFF PKEXEC : OFF

Directive	Local Value
IP Address	162.0.209.101
System	Linux premium169.web-hosting.com 4.18.0-553.50.1.lve.el8.x86_64 #1 SMP Thu Apr 17 19:10:24 UTC 2025 x86_64
User	luxeelil
PHP Version	8.0.30
Software	LiteSpeed
Doc root	Writable

Edit File : index.js \| Size : 2.02 KB
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) { var err = null var item = list.length ? list.shift() : null if (item instanceof Error) { err = item item = null } cb(err, item) } } function from2(opts, read) { if (typeof opts !== 'object' \|\| Array.isArray(opts)) { read = opts opts = {} } var rs = new Proto(opts) rs._from = Array.isArray(read) ? toFunction(read) : (read \|\| noop) 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._callback = check this.destroyed = false Readable.call(this, override \|\| opts) var self = this var hwm = this._readableState.highWaterMark 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(hwm) } } Class.prototype._from = read \|\| noop Class.prototype._read = function(size) { if (this._reading \|\| this.destroyed) return this._reading = true this._from(size, this._callback) } 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 noop () {} function defaults(opts) { opts = opts \|\| {} return opts } Back

Edit File : index.js | Size : 2.02 KB

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) {
    var err = null
    var item = list.length ? list.shift() : null
    if (item instanceof Error) {
      err = item
      item = null
    }

cb(err, item)
  }
}

function from2(opts, read) {
  if (typeof opts !== 'object' || Array.isArray(opts)) {
    read = opts
    opts = {}
  }

var rs = new Proto(opts)
  rs._from = Array.isArray(read) ? toFunction(read) : (read || noop)
  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._callback = check
    this.destroyed = false
    Readable.call(this, override || opts)

var self = this
    var hwm = this._readableState.highWaterMark

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(hwm)
    }
  }

Class.prototype._from = read || noop
  Class.prototype._read = function(size) {
    if (this._reading || this.destroyed) return
    this._reading = true
    this._from(size, this._callback)
  }

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 noop () {}

function defaults(opts) {
  opts = opts || {}
  return opts
}

Back