Sha256: 53bb4241793f909588dfe40caeaa8bb7b478c10ab45b8f1c726f140557488529
Contents?: true
Size: 1.03 KB
Versions: 35
Compression:
Stored size: 1.03 KB
Contents
'use strict'
var nextTick = nextTickArgs
process.nextTick(upgrade, 42) // pass 42 and see if upgrade is called with it
module.exports = thunky
function thunky (fn) {
var state = run
return thunk
function thunk (callback) {
state(callback || noop)
}
function run (callback) {
var stack = [callback]
state = wait
fn(done)
function wait (callback) {
stack.push(callback)
}
function done (err) {
var args = arguments
state = isError(err) ? run : finished
while (stack.length) finished(stack.shift())
function finished (callback) {
nextTick(apply, callback, args)
}
}
}
}
function isError (err) { // inlined from util so this works in the browser
return Object.prototype.toString.call(err) === '[object Error]'
}
function noop () {}
function apply (callback, args) {
callback.apply(null, args)
}
function upgrade (val) {
if (val === 42) nextTick = process.nextTick
}
function nextTickArgs (fn, a, b) {
process.nextTick(function () {
fn(a, b)
})
}
Version data entries
35 entries across 34 versions & 11 rubygems