builtins.js

/*** Generated by streamline 0.2.5 - DO NOT EDIT ***/ var __rt=require('streamline/lib/callbacks/runtime').runtime(__filename),__func=__rt.__func,__cb=__rt.__cb,__propagate=__rt.__propagate,__trap=__rt.__trap,__future=__rt.__future,__setEF=__rt.__setEF,__g=__rt.__g; (function(exports) {








 "use strict";

 var future = function(fn, args, i) {
 var err, result, done, q = [], self = this;

 args = Array.prototype.slice.call(args);
 args[i] = function(e, r) {
 err = e, result = r, done = true;
 (q && q.forEach(function(f) {
 f.call(self, e, r); }));

 q = null; };

 fn.apply(this, args);
 return function F(cb) {
 if (!cb) { return F };
 if (done) { cb.call(self, err, result); } else {
 q.push(cb); }; }; };




 exports.funnel = function(max) {
 max = ((max == null) ? -1 : max);
 if ((max === 0)) { max = funnel.defaultSize; };
 if ((typeof max !== "number")) { throw new Error(("bad max number: " + max)) };
 var queue = [], active = 0, closed = false;



 var fun = function(callback, fn) {
 if ((callback == null)) { return future(fun, arguments, 0) };

 if (((max < 0) || (max == Infinity))) { return fn(callback) };

 queue.push({
 fn: fn,
 cb: callback });


 function _doOne() {
 var current = queue.splice(0, 1)[0];
 if (!current.cb) { return current.fn() };
 active++;
 current.fn(function(err, result) {
 active--;
 if (!closed) {
 current.cb(err, result);
 while (((active < max) && (queue.length > 0))) { _doOne();; }; } ; }); };




 while (((active < max) && (queue.length > 0))) { _doOne();; }; };

 fun.close = function() {
 queue = [], closed = true; };

 return fun; };

 var funnel = exports.funnel;
 funnel.defaultSize = 4;

 function _parallel(options) {
 if ((typeof options === "number")) { return options };
 if ((typeof options.parallel === "number")) { return options.parallel };
 return (options.parallel ? -1 : 1); };

























 Array.prototype.forEach_ = function Array_prototype_forEach___1(_, options, fn, thisObj) { var par, len, i, __this = this; var __frame = { name: "Array_prototype_forEach___1", line: 102 }; return __func(_, this, arguments, Array_prototype_forEach___1, 0, __frame, function __$Array_prototype_forEach___1() {
 if ((typeof options === "function")) { thisObj = fn, fn = options, options = 1; } ;
 par = _parallel(options);
 thisObj = ((thisObj !== undefined) ? thisObj : __this);
 len = __this.length; return (function __$Array_prototype_forEach___1(__then) {
 if (((par === 1) || (len <= 1))) {
 i = 0; var __2 = false; return (function ___(__break) { var __more; var __loop = __cb(_, __frame, 0, 0, function __$Array_prototype_forEach___1() { __more = false; if (__2) { i++; } else { __2 = true; } ; var __1 = (i < len); if (__1) {
 return fn.call(thisObj, __cb(_, __frame, 7, 3, function __$Array_prototype_forEach___1() { while (__more) { __loop(); }; __more = true; }, true), __this[i], i); } else { __break(); } ; }); do { __loop(); } while (__more); __more = true; })(__then); } else {

 return __this.map_(__cb(_, __frame, 9, 3, __then, true), par, fn, thisObj); } ; })(function __$Array_prototype_forEach___1() { return _(null, __this); }); }); };





 Array.prototype.map_ = function Array_prototype_map___2(_, options, fn, thisObj) { var par, len, result, i, fun, __this = this; var __frame = { name: "Array_prototype_map___2", line: 117 }; return __func(_, this, arguments, Array_prototype_map___2, 0, __frame, function __$Array_prototype_map___2() {
 if ((typeof options === "function")) { thisObj = fn, fn = options, options = 1; } ;
 par = _parallel(options);
 thisObj = ((thisObj !== undefined) ? thisObj : __this);
 len = __this.length; return (function __$Array_prototype_map___2(__then) {

 if (((par === 1) || (len <= 1))) {
 result = [];
 i = 0; var __4 = false; return (function ___(__break) { var __more; var __loop = __cb(_, __frame, 0, 0, function __$Array_prototype_map___2() { __more = false; if (__4) { i++; } else { __4 = true; } ; var __3 = (i < len); if (__3) {
 return fn.call(thisObj, __cb(_, __frame, 9, 15, function ___(__0, __1) { result[i] = __1; while (__more) { __loop(); }; __more = true; }, true), __this[i], i); } else { __break(); } ; }); do { __loop(); } while (__more); __more = true; })(__then); } else {

 fun = funnel(par);
 result = __this.map(function(elt, i) {
 return fun(null, function __1(_) { var __frame = { name: "__1", line: 130 }; return __func(_, this, arguments, __1, 0, __frame, function __$__1() {
 return fn.call(thisObj, __cb(_, __frame, 1, 12, _, true), elt, i); }); }); });


 i = 0; var __7 = false; return (function ___(__break) { var __more; var __loop = __cb(_, __frame, 0, 0, function __$Array_prototype_map___2() { __more = false; if (__7) { i++; } else { __7 = true; } ; var __6 = (i < len); if (__6) { return result[i](__cb(_, __frame, 17, 45, function ___(__0, __2) { result[i] = __2; while (__more) { __loop(); }; __more = true; }, true)); } else { __break(); } ; }); do { __loop(); } while (__more); __more = true; })(__then); } ; })(function __$Array_prototype_map___2() {

 return _(null, result); }); }); };



 Array.prototype.filter_ = function Array_prototype_filter___3(_, options, fn, thisObj) { var par, result, len, i, elt, __this = this; var __frame = { name: "Array_prototype_filter___3", line: 140 }; return __func(_, this, arguments, Array_prototype_filter___3, 0, __frame, function __$Array_prototype_filter___3() {
 if ((typeof options === "function")) { thisObj = fn, fn = options, options = 1; } ;
 par = _parallel(options);
 thisObj = ((thisObj !== undefined) ? thisObj : __this);
 result = [];
 len = __this.length; return (function __$Array_prototype_filter___3(__then) {
 if (((par === 1) || (len <= 1))) {
 i = 0; var __4 = false; return (function ___(__break) { var __more; var __loop = __cb(_, __frame, 0, 0, function __$Array_prototype_filter___3() { __more = false; if (__4) { i++; } else { __4 = true; } ; var __3 = (i < len); if (__3) {
 elt = __this[i];
 return fn.call(thisObj, __cb(_, __frame, 9, 8, function ___(__0, __2) { return (function __$Array_prototype_filter___3(__then) { if (__2) { result.push(elt); __then(); } else { __then(); } ; })(function __$Array_prototype_filter___3() { while (__more) { __loop(); }; __more = true; }); }, true), elt); } else { __break(); } ; }); do { __loop(); } while (__more); __more = true; })(__then); } else {


 return __this.map_(__cb(_, __frame, 12, 3, __then, true), par, function __1(_, elt) { var __frame = { name: "__1", line: 152 }; return __func(_, this, arguments, __1, 0, __frame, function __$__1() {
 return fn.call(thisObj, __cb(_, __frame, 1, 8, function ___(__0, __1) { return (function __$__1(__then) { if (__1) { result.push(elt); __then(); } else { __then(); } ; })(_); }, true), elt); });
 }, thisObj); } ; })(function __$Array_prototype_filter___3() {

 return _(null, result); }); }); };



 Array.prototype.every_ = function Array_prototype_every___4(_, options, fn, thisObj) { var par, len, i, fun, futures, __this = this; var __frame = { name: "Array_prototype_every___4", line: 160 }; return __func(_, this, arguments, Array_prototype_every___4, 0, __frame, function __$Array_prototype_every___4() {
 if ((typeof options === "function")) { thisObj = fn, fn = options, options = 1; } ;
 par = _parallel(options);
 thisObj = ((thisObj !== undefined) ? thisObj : __this);
 len = __this.length; return (function __$Array_prototype_every___4(__then) {
 if (((par === 1) || (len <= 1))) {
 i = 0; var __6 = false; return (function ___(__break) { var __more; var __loop = __cb(_, __frame, 0, 0, function __$Array_prototype_every___4() { __more = false; if (__6) { i++; } else { __6 = true; } ; var __5 = (i < len); if (__5) {
 return fn.call(thisObj, __cb(_, __frame, 7, 9, function ___(__0, __2) { var __1 = !__2; return (function __$Array_prototype_every___4(__then) { if (__1) { return _(null, false); } else { __then(); } ; })(function __$Array_prototype_every___4() { while (__more) { __loop(); }; __more = true; }); }, true), __this[i]); } else { __break(); } ; }); do { __loop(); } while (__more); __more = true; })(__then); } else {


 fun = funnel(par);
 futures = __this.map(function(elt) {
 return fun(null, function __1(_) { var __frame = { name: "__1", line: 172 }; return __func(_, this, arguments, __1, 0, __frame, function __$__1() {
 return fn.call(thisObj, __cb(_, __frame, 1, 12, _, true), elt); }); }); });


 i = 0; var __9 = false; return (function ___(__break) { var __more; var __loop = __cb(_, __frame, 0, 0, function __$Array_prototype_every___4() { __more = false; if (__9) { i++; } else { __9 = true; } ; var __8 = (i < len); if (__8) {
 return futures[i](__cb(_, __frame, 17, 9, function ___(__0, __4) { var __3 = !__4; return (function __$Array_prototype_every___4(__then) { if (__3) {
 fun.close();
 return _(null, false); } else { __then(); } ; })(function __$Array_prototype_every___4() { while (__more) { __loop(); }; __more = true; }); }, true)); } else { __break(); } ; }); do { __loop(); } while (__more); __more = true; })(__then); } ; })(function __$Array_prototype_every___4() {



 return _(null, true); }); }); };



 Array.prototype.some_ = function Array_prototype_some___5(_, options, fn, thisObj) { var par, len, i, fun, futures, __this = this; var __frame = { name: "Array_prototype_some___5", line: 187 }; return __func(_, this, arguments, Array_prototype_some___5, 0, __frame, function __$Array_prototype_some___5() {
 if ((typeof options === "function")) { thisObj = fn, fn = options, options = 1; } ;
 par = _parallel(options);
 thisObj = ((thisObj !== undefined) ? thisObj : __this);
 len = __this.length; return (function __$Array_prototype_some___5(__then) {
 if (((par === 1) || (len <= 1))) {
 i = 0; var __4 = false; return (function ___(__break) { var __more; var __loop = __cb(_, __frame, 0, 0, function __$Array_prototype_some___5() { __more = false; if (__4) { i++; } else { __4 = true; } ; var __3 = (i < len); if (__3) {
 return fn.call(thisObj, __cb(_, __frame, 7, 8, function ___(__0, __1) { return (function __$Array_prototype_some___5(__then) { if (__1) { return _(null, true); } else { __then(); } ; })(function __$Array_prototype_some___5() { while (__more) { __loop(); }; __more = true; }); }, true), __this[i]); } else { __break(); } ; }); do { __loop(); } while (__more); __more = true; })(__then); } else {


 fun = funnel(par);
 futures = __this.map(function(elt) {
 return fun(null, function __1(_) { var __frame = { name: "__1", line: 199 }; return __func(_, this, arguments, __1, 0, __frame, function __$__1() {
 return fn.call(thisObj, __cb(_, __frame, 1, 12, _, true), elt); }); }); });


 i = 0; var __7 = false; return (function ___(__break) { var __more; var __loop = __cb(_, __frame, 0, 0, function __$Array_prototype_some___5() { __more = false; if (__7) { i++; } else { __7 = true; } ; var __6 = (i < len); if (__6) {
 return futures[i](__cb(_, __frame, 17, 8, function ___(__0, __2) { return (function __$Array_prototype_some___5(__then) { if (__2) {
 fun.close();
 return _(null, true); } else { __then(); } ; })(function __$Array_prototype_some___5() { while (__more) { __loop(); }; __more = true; }); }, true)); } else { __break(); } ; }); do { __loop(); } while (__more); __more = true; })(__then); } ; })(function __$Array_prototype_some___5() {



 return _(null, false); }); }); };



 Array.prototype.reduce_ = function Array_prototype_reduce___6(_, fn, v, thisObj) { var len, i, __this = this; var __frame = { name: "Array_prototype_reduce___6", line: 214 }; return __func(_, this, arguments, Array_prototype_reduce___6, 0, __frame, function __$Array_prototype_reduce___6() {
 thisObj = ((thisObj !== undefined) ? thisObj : __this);
 len = __this.length;
 i = 0; var __3 = false; return (function ___(__break) { var __more; var __loop = __cb(_, __frame, 0, 0, function __$Array_prototype_reduce___6() { __more = false; if (__3) { i++; } else { __3 = true; } ; var __2 = (i < len); if (__2) {
 return fn.call(thisObj, __cb(_, __frame, 4, 7, function ___(__0, __1) { v = __1; while (__more) { __loop(); }; __more = true; }, true), v, __this[i], i, __this); } else { __break(); } ; }); do { __loop(); } while (__more); __more = true; })(function __$Array_prototype_reduce___6() {

 return _(null, v); }); }); };



 Array.prototype.reduceRight_ = function Array_prototype_reduceRight___7(_, fn, v, thisObj) { var len, i, __this = this; var __frame = { name: "Array_prototype_reduceRight___7", line: 224 }; return __func(_, this, arguments, Array_prototype_reduceRight___7, 0, __frame, function __$Array_prototype_reduceRight___7() {
 thisObj = ((thisObj !== undefined) ? thisObj : __this);
 len = __this.length;
 i = (len - 1); var __3 = false; return (function ___(__break) { var __more; var __loop = __cb(_, __frame, 0, 0, function __$Array_prototype_reduceRight___7() { __more = false; if (__3) { i--; } else { __3 = true; } ; var __2 = (i >= 0); if (__2) {
 return fn.call(thisObj, __cb(_, __frame, 4, 7, function ___(__0, __1) { v = __1; while (__more) { __loop(); }; __more = true; }, true), v, __this[i], i, __this); } else { __break(); } ; }); do { __loop(); } while (__more); __more = true; })(function __$Array_prototype_reduceRight___7() {

 return _(null, v); }); }); };





 Array.prototype.sort_ = function Array_prototype_sort___8(_, compare, beg, end) { var array, __this = this;




 function _qsort(_, beg, end) { var tmp, mid, o, nbeg, nend; var __frame = { name: "_qsort", line: 241 }; return __func(_, this, arguments, _qsort, 0, __frame, function __$_qsort() {
 if ((beg >= end)) { return _(null); } ; return (function __$_qsort(__then) {

 if ((end == (beg + 1))) {
 return compare(__cb(_, __frame, 4, 8, function ___(__0, __2) { var __1 = (__2 > 0); return (function __$_qsort(__then) { if (__1) {
 tmp = array[beg];
 array[beg] = array[end];
 array[end] = tmp; __then(); } else { __then(); } ; })(function __$_qsort() { return _(null); }); }, true), array[beg], array[end]); } else { __then(); } ; })(function __$_qsort() {




 mid = Math.floor((((beg + end)) / 2));
 o = array[mid];
 nbeg = beg;
 nend = end; return (function ___(__break) { var __more; var __loop = __cb(_, __frame, 0, 0, function __$_qsort() { __more = false;

 var __4 = (nbeg <= nend); if (__4) { return (function ___(__break) { var __more; var __loop = __cb(_, __frame, 0, 0, function __$_qsort() { __more = false; return (function __$_qsort(_) { return (function __$_qsort(_) {
 var __1 = (nbeg < end); if (!__1) { return _(null, __1); } ; return compare(__cb(_, __frame, 18, 25, function ___(__0, __3) { var __2 = (__3 < 0); return _(null, __2); }, true), array[nbeg], o); })(__cb(_, __frame, -240, 17, _, true)); })(__cb(_, __frame, -240, 17, function ___(__0, __5) { if (__5) { nbeg++; while (__more) { __loop(); }; __more = true; } else { __break(); } ; }, true)); }); do { __loop(); } while (__more); __more = true; })(function __$_qsort() { return (function ___(__break) { var __more; var __loop = __cb(_, __frame, 0, 0, function __$_qsort() { __more = false; return (function __$_qsort(_) { return (function __$_qsort(_) {
 var __1 = (beg < nend); if (!__1) { return _(null, __1); } ; return compare(__cb(_, __frame, 19, 25, function ___(__0, __3) { var __2 = (__3 < 0); return _(null, __2); }, true), o, array[nend]); })(__cb(_, __frame, -240, 17, _, true)); })(__cb(_, __frame, -240, 17, function ___(__0, __7) { if (__7) { nend--; while (__more) { __loop(); }; __more = true; } else { __break(); } ; }, true)); }); do { __loop(); } while (__more); __more = true; })(function __$_qsort() {

 if ((nbeg <= nend)) {
 tmp = array[nbeg];
 array[nbeg] = array[nend];
 array[nend] = tmp;
 nbeg++;
 nend--; } ; while (__more) { __loop(); }; __more = true; }); }); } else { __break(); } ; }); do { __loop(); } while (__more); __more = true; })(function __$_qsort() { return (function __$_qsort(__then) {



 if ((nbeg < end)) { return _qsort(__cb(_, __frame, 30, 19, __then, true), nbeg, end); } else { __then(); } ; })(function __$_qsort() { return (function __$_qsort(__then) {
 if ((beg < nend)) { return _qsort(__cb(_, __frame, 31, 19, __then, true), beg, nend); } else { __then(); } ; })(_); }); }); }); }); }; var __frame = { name: "Array_prototype_sort___8", line: 236 }; return __func(_, this, arguments, Array_prototype_sort___8, 0, __frame, function __$Array_prototype_sort___8() { array = __this; beg = (beg || 0); end = ((end == null) ? (array.length - 1) : end);

 return _qsort(__cb(_, __frame, 38, 2, function __$Array_prototype_sort___8() {
 return _(null, array); }, true), beg, end); }); };










 Function.prototype.apply_ = function(callback, thisObj, args, index) {
 Array.prototype.splice.call(args, ((index != null) ? index : args.length), 0, callback);
 return this.apply(thisObj, args); };

})(((typeof exports !== "undefined") ? exports : (window.StreamlineBuiltins = (window.StreamlineBuiltins || {}))));