?HAMA

Edit File Size: 2.89 KB

/home/byroehnu/.trash/node_modules11/asynckit/lib/streamify.js

Text Base64

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);
}

Exit & Reset Text mode: syntax highlighting auto-detects file type.

Name	Size	Perms	Modified	Actions
abort.js	497 B	lrw-r--r--	2026-02-20 03:53:00	Edit Download recursive recursive
async.js	599 B	lrw-r--r--	2026-02-20 03:53:00	Edit Download recursive recursive
defer.js	441 B	lrw-r--r--	2026-02-20 03:53:00	Edit Download recursive recursive
iterate.js	1.75 KB	lrw-r--r--	2026-02-20 03:53:00	Edit Download recursive recursive
readable_asynckit.js	1.57 KB	lrw-r--r--	2026-02-20 03:53:00	Edit Download recursive recursive
readable_parallel.js	673 B	lrw-r--r--	2026-02-20 03:53:00	Edit Download recursive recursive
readable_serial.js	655 B	lrw-r--r--	2026-02-20 03:53:00	Edit Download recursive recursive
readable_serial_ordered.js	941 B	lrw-r--r--	2026-02-20 03:53:00	Edit Download recursive recursive
state.js	941 B	lrw-r--r--	2026-02-20 03:53:00	Edit Download recursive recursive
streamify.js	2.89 KB	lrw-r--r--	2026-02-20 03:53:00	Edit Download recursive recursive
terminator.js	533 B	lrw-r--r--	2026-02-20 03:53:00	Edit Download recursive recursive

Directory Contents