96 lines
1.4 KiB
JavaScript
96 lines
1.4 KiB
JavaScript
function Async() {
|
|
return {
|
|
apply: apply,
|
|
bind: bind,
|
|
parallel: parallel,
|
|
run: run,
|
|
sequence: sequence,
|
|
wait: wait,
|
|
wrap: wrap
|
|
};
|
|
|
|
function apply(f, x) {
|
|
return function(g) {
|
|
g(f(x));
|
|
};
|
|
}
|
|
|
|
function bind() {
|
|
var m, steps, i;
|
|
if(arguments.length < 1) {
|
|
return wrap();
|
|
}
|
|
m = arguments[0];
|
|
steps = arguments;
|
|
i = 1;
|
|
return function(f) {
|
|
var step = function(x) {
|
|
if(i < steps.length) {
|
|
steps[i++](x)(step);
|
|
} else {
|
|
return f(x);
|
|
}
|
|
}
|
|
m(step);
|
|
};
|
|
}
|
|
|
|
function parallel() {
|
|
var threads = arguments;
|
|
var pending = threads.length;
|
|
var results = [];
|
|
return function(f) {
|
|
var useResult = function(i) {
|
|
return function(x) {
|
|
results[i] = x;
|
|
pending--;
|
|
if(pending < 1) {
|
|
f(results);
|
|
}
|
|
};
|
|
};
|
|
for(var i = 0; i < threads.length; i++) {
|
|
threads[i](useResult(i));
|
|
}
|
|
};
|
|
}
|
|
|
|
function run() {
|
|
var m;
|
|
if(arguments.length == 1) {
|
|
m = arguments[0];
|
|
} else {
|
|
m = sequence.apply(null, arguments);
|
|
}
|
|
m(function() {});
|
|
}
|
|
|
|
function sequence() {
|
|
var steps = arguments;
|
|
var i = 0;
|
|
return function(f) {
|
|
var step = function(x) {
|
|
if(i < steps.length) {
|
|
steps[i++](step);
|
|
} else {
|
|
f(x);
|
|
}
|
|
}
|
|
step();
|
|
};
|
|
}
|
|
|
|
function wait(delay) {
|
|
return function(f) {
|
|
setTimeout(f, delay);
|
|
};
|
|
}
|
|
|
|
function wrap(x) {
|
|
return function(f) {
|
|
f(x);
|
|
};
|
|
}
|
|
|
|
}
|