ysjj-system/node_modules/chan/lib/async.js

/**
 * Module dependencies.
 */
var Receiver = require('./receiver')

/**
 * Expose `async`.
 */
module.exports = async

/**
 * Add value to channel via node-style async function.
 *
 * @param {Function} channel
 * @param {Function|Object} fn async function or object with async method
 * @param {String} method name only if fn is an object
 * @param {mixed} args async function arguments without callback
 * @return {Function} thunk
 */
function async(ch, fn/*, args...*/) {
  var args     = [].slice.call(arguments, 2)
  var receiver = new Receiver()
  var context  = null

  if (typeof fn === 'object') {
    context = fn
    fn = fn[args.shift()]
  }

  args.push(function (err, val) {
    if (arguments.length > 2) {
      val = [].slice.call(arguments, 1)
    }
    ch(err, val)(function (err) {
      receiver[err ? 'error' : 'add'](err)
    })
  })

  fn.apply(context, args)

  return function (cb) {
    receiver.callback(cb)
  }
}