Graybyt3 Was Here

Linux business121.web-hosting.com 4.18.0-513.11.1.lve.el8.x86_64 #1 SMP Thu Jan 18 16:21:02 UTC 2024 x86_64
LiteSpeed
192.64.117.91

File Name : readable_asynckit.js

var streamify = require('./streamify.js')
  , defer     = require('./defer.js')
  ;

// API
module.exports = ReadableAsyncKit;

/**
 * Base constructor for all streams
 * used to hold properties/methods
 */
function ReadableAsyncKit()
{
  ReadableAsyncKit.super_.apply(this, arguments);

// list of active jobs
  this.jobs = {};

// add stream methods
  this.destroy = destroy;
  this._start  = _start;
  this._read   = _read;
}

/**
 * Destroys readable stream,
 * by aborting outstanding jobs
 *
 * @returns {void}
 */
function destroy()
{
  if (this.destroyed)
  {
    return;
  }

this.destroyed = true;

if (typeof this.terminator == 'function')
  {
    this.terminator();
  }
}

/**
 * Starts provided jobs in async manner
 *
 * @private
 */
function _start()
{
  // first argument – runner function
  var runner = arguments[0]
    // take away first argument
    , args   = Array.prototype.slice.call(arguments, 1)
      // second argument - input data
    , input  = args[0]
      // last argument - result callback
    , endCb  = streamify.callback.call(this, args[args.length - 1])
    ;

args[args.length - 1] = endCb;
  // third argument - iterator
  args[1] = streamify.iterator.call(this, args[1]);

// allow time for proper setup
  defer(function()
  {
    if (!this.destroyed)
    {
      this.terminator = runner.apply(null, args);
    }
    else
    {
      endCb(null, Array.isArray(input) ? [] : {});
    }
  }.bind(this));
}

/**
 * Implement _read to comply with Readable streams
 * Doesn't really make sense for flowing object mode
 *
 * @private
 */
function _read()
{

}

System Information
*ReClick For Close
File : BlackDragon /simple/function.php

Name	Type	Size	Owner/Group	Permission	Last Modified	Actions
.	dir	-	root/root	0755	2024-03-03 10:41:56
..	dir	-	root/root	0755	2024-03-03 10:41:56
abort.js	text/plain	497 B	root/root	0644	2021-09-28 10:29:18
async.js	text/plain	599 B	root/root	0644	2021-09-28 10:29:18
defer.js	text/plain	441 B	root/root	0644	2021-09-28 10:29:18
iterate.js	text/plain	1.75 KB	root/root	0644	2021-09-28 10:29:18
readable_asynckit.js	text/plain	1.57 KB	root/root	0644	2021-09-28 10:29:18
readable_parallel.js	text/plain	673 B	root/root	0644	2021-09-28 10:29:18
readable_serial.js	text/plain	655 B	root/root	0644	2021-09-28 10:29:18
readable_serial_ordered.js	text/plain	941 B	root/root	0644	2021-09-28 10:29:18
state.js	text/plain	941 B	root/root	0644	2021-09-28 10:29:18
streamify.js	text/plain	2.89 KB	root/root	0644	2021-09-28 10:29:18
terminator.js	text/plain	533 B	root/root	0644	2021-09-28 10:29:18