aDriv4 website!

Linux stg-1 5.15.0-94-generic #104-Ubuntu SMP Tue Jan 9 15:25:40 UTC 2024 x86_64
nginx/1.24.0
102.222.106.62

File Name : streamify.js

var async = require('./async.js');

// API
module.exports = {
  iterator: wrapIterator,
  callback: wrapCallback
};

/**
 * Wraps iterators with long signature
 *
 * @this    ReadableAsyncKit#
 * @param   {function} iterator - function to wrap
 * @returns {function} - wrapped function
 */
function wrapIterator(iterator)
{
  var stream = this;

return function(item, key, cb)
  {
    var aborter
      , wrappedCb = async(wrapIteratorCallback.call(stream, cb, key))
      ;

stream.jobs[key] = wrappedCb;

// it's either shortcut (item, cb)
    if (iterator.length == 2)
    {
      aborter = iterator(item, wrappedCb);
    }
    // or long format (item, key, cb)
    else
    {
      aborter = iterator(item, key, wrappedCb);
    }

return aborter;
  };
}

/**
 * Wraps provided callback function
 * allowing to execute snitch function before
 * real callback
 *
 * @this    ReadableAsyncKit#
 * @param   {function} callback - function to wrap
 * @returns {function} - wrapped function
 */
function wrapCallback(callback)
{
  var stream = this;

var wrapped = function(error, result)
  {
    return finisher.call(stream, error, result, callback);
  };

return wrapped;
}

/**
 * Wraps provided iterator callback function
 * makes sure snitch only called once,
 * but passes secondary calls to the original callback
 *
 * @this    ReadableAsyncKit#
 * @param   {function} callback - callback to wrap
 * @param   {number|string} key - iteration key
 * @returns {function} wrapped callback
 */
function wrapIteratorCallback(callback, key)
{
  var stream = this;

return function(error, output)
  {
    // don't repeat yourself
    if (!(key in stream.jobs))
    {
      callback(error, output);
      return;
    }

// clean up jobs
    delete stream.jobs[key];

return streamer.call(stream, error, {key: key, value: output}, callback);
  };
}

/**
 * Stream wrapper for iterator callback
 *
 * @this  ReadableAsyncKit#
 * @param {mixed} error - error response
 * @param {mixed} output - iterator output
 * @param {function} callback - callback that expects iterator results
 */
function streamer(error, output, callback)
{
  if (error && !this.error)
  {
    this.error = error;
    this.pause();
    this.emit('error', error);
    // send back value only, as expected
    callback(error, output && output.value);
    return;
  }

// stream stuff
  this.push(output);

// back to original track
  // send back value only, as expected
  callback(error, output && output.value);
}

/**
 * Stream wrapper for finishing callback
 *
 * @this  ReadableAsyncKit#
 * @param {mixed} error - error response
 * @param {mixed} output - iterator output
 * @param {function} callback - callback that expects final results
 */
function finisher(error, output, callback)
{
  // signal end of the stream
  // only for successfully finished streams
  if (!error)
  {
    this.push(null);
  }

// back to original track
  callback(error, output);
}

Name	Type	Size	Owner/Group	Permission	Last Modified	Actions
.	dir	-	forge/forge	0775	2023-12-04 05:16:08
..	dir	-	forge/forge	0775	2023-12-04 05:16:08
abort.js	text/plain	497 B	forge/forge	0664	2023-12-04 05:16:08
async.js	text/plain	599 B	forge/forge	0664	2023-12-04 05:16:08
defer.js	text/plain	441 B	forge/forge	0664	2023-12-04 05:16:08
iterate.js	text/plain	1.75 KB	forge/forge	0664	2023-12-04 05:16:08
readable_asynckit.js	text/plain	1.57 KB	forge/forge	0664	2023-12-04 05:16:08
readable_parallel.js	text/plain	673 B	forge/forge	0664	2023-12-04 05:16:08
readable_serial.js	text/plain	655 B	forge/forge	0664	2023-12-04 05:16:08
readable_serial_ordered.js	text/plain	941 B	forge/forge	0664	2023-12-04 05:16:08
state.js	text/plain	941 B	forge/forge	0664	2023-12-04 05:16:08
streamify.js	text/plain	2.89 KB	forge/forge	0664	2023-12-04 05:16:08
terminator.js	text/plain	533 B	forge/forge	0664	2023-12-04 05:16:08

For more Private tool come to me!

https://t.me/aDriv4vz