New Case Study:See how Anthropic automated 95% of dependency reviews with Socket.Learn More →
Socket
Sign inDemoInstall
Socket
Sign inDemoInstall

streamline

Package Overview
Dependencies
Maintainers
1
Versions
138
Alerts
File Explorer

Advanced tools

License
Socket logo

Install Socket

Detect and block malicious and high-risk dependencies

Install

streamline - npm Package Compare versions

Comparing version 0.1.39 to 0.1.40

21

examples/diskUsage/diskUsage.js

@@ -1,7 +0,6 @@

/*** Generated by streamline 0.1.39 - DO NOT EDIT ***/
var __g=typeof global!=='undefined'?global:window;__g=(__g.__streamline||(__g.__streamline={}));__g.setEF=__g.setEF||function(e,f){e.__frame = e.__frame||f};__g.cbTick = 0;var __nextTick=(typeof process!='undefined'&&typeof process.nextTick=='function')?process.nextTick:function(fn){setTimeout(function(){fn()},0);};var __srcName='./examples/diskUsage/diskUsage_.js';
function __func(_, __this, __arguments, fn, index, frame, body){ if (!_) { return __future.call(__this, fn, __arguments, index); } frame.file = __srcName; frame.prev = __g.frame; if ((__g.cbTick = ++__g.cbTick % 100) === 0) return __nextTick(__cb(_, frame, -1, 0, body)); __g.frame = frame; try { body(); } catch (e) { __g.setEF(e, frame.prev); __propagate(_, e); } finally { __g.frame = frame.prev; } }
/*** Generated by streamline 0.1.40 - DO NOT EDIT ***/
var __g=typeof global!=='undefined'?global:window;__g=(__g.__streamline||(__g.__streamline={}));__g.setEF=__g.setEF||function(e,f){e.__frame = e.__frame||f};var __srcName='../streamline/examples/diskUsage/diskUsage_.js';
function __func(_, __this, __arguments, fn, index, frame, body){ if (!_) { return __future.call(__this, fn, __arguments, index); } frame.file = __srcName; frame.prev = __g.frame; __g.frame = frame; try { body(); } catch (e) { __g.setEF(e, frame.prev); __propagate(_, e); } finally { __g.frame = frame.prev; } }
function __cb(_, frame, offset, col, fn){ frame.offset = offset; frame.col = col; var ctx = __g.context; return function ___(err, result){ var oldFrame = __g.frame; __g.frame = frame; __g.context = ctx; try { if (err) { __g.setEF(err, frame); return _(err); } return fn(null, result); } catch (ex) { __g.setEF(ex, frame); return __propagate(_, ex); } finally { __g.frame = oldFrame; } } }
function __future(fn, args, i){ var done, err, result; var cb = function(e, r){ done = true; err = e, result = r; }; args = Array.prototype.slice.call(args); args[i] = function ___(e, r){ cb(e, r); }; fn.apply(this, args); return function ___(_){ if (done) _.call(this, err, result); else cb = _.bind(this); } .bind(this); }
function __nt(_, frame, fn){ var cb = __cb(_, frame, 0, 0, fn); return function ___(){ if ((__g.cbTick = ++__g.cbTick % 100) === 0) __nextTick(cb); else cb(); }; }
function __propagate(_, err){ try { _(err); } catch (ex) { __trap(ex); } }

@@ -37,3 +36,5 @@ function __trap(err){ if (err) { if (__g.context && __g.context.errorHandler) __g.context.errorHandler(err); else console.error("UNCAUGHT EXCEPTION: " + err.message + "\n" + err.stack); } }

return (function ___(__break) {
var __loop = __nt(_, __frame, function __$du() {
var __more;
var __loop = __cb(_, __frame, 0, 0, function __$du() {
__more = false;
if (__9) {

@@ -50,3 +51,6 @@ /* 21 */ i++;

/* 22 */ total += __4;
__loop();
while (__more) {
__loop();
};
__more = true;
/* 22 */ }), ((path + "/") + files[i]));

@@ -59,3 +63,6 @@ }

});
__loop();
do {
__loop();
} while (__more);
__more = true;
})(function __$du() {

@@ -62,0 +69,0 @@ /* 24 */ console.log(((path + ": ") + total));

6

examples/diskUsage/diskUsage2.js

@@ -1,4 +0,4 @@

/*** Generated by streamline 0.1.39 - DO NOT EDIT ***/
var __g=typeof global!=='undefined'?global:window;__g=(__g.__streamline||(__g.__streamline={}));__g.setEF=__g.setEF||function(e,f){e.__frame = e.__frame||f};__g.cbTick = 0;var __nextTick=(typeof process!='undefined'&&typeof process.nextTick=='function')?process.nextTick:function(fn){setTimeout(function(){fn()},0);};var __srcName='./examples/diskUsage/diskUsage2_.js';
function __func(_, __this, __arguments, fn, index, frame, body){ if (!_) { return __future.call(__this, fn, __arguments, index); } frame.file = __srcName; frame.prev = __g.frame; if ((__g.cbTick = ++__g.cbTick % 100) === 0) return __nextTick(__cb(_, frame, -1, 0, body)); __g.frame = frame; try { body(); } catch (e) { __g.setEF(e, frame.prev); __propagate(_, e); } finally { __g.frame = frame.prev; } }
/*** Generated by streamline 0.1.40 - DO NOT EDIT ***/
var __g=typeof global!=='undefined'?global:window;__g=(__g.__streamline||(__g.__streamline={}));__g.setEF=__g.setEF||function(e,f){e.__frame = e.__frame||f};var __srcName='../streamline/examples/diskUsage/diskUsage2_.js';
function __func(_, __this, __arguments, fn, index, frame, body){ if (!_) { return __future.call(__this, fn, __arguments, index); } frame.file = __srcName; frame.prev = __g.frame; __g.frame = frame; try { body(); } catch (e) { __g.setEF(e, frame.prev); __propagate(_, e); } finally { __g.frame = frame.prev; } }
function __cb(_, frame, offset, col, fn){ frame.offset = offset; frame.col = col; var ctx = __g.context; return function ___(err, result){ var oldFrame = __g.frame; __g.frame = frame; __g.context = ctx; try { if (err) { __g.setEF(err, frame); return _(err); } return fn(null, result); } catch (ex) { __g.setEF(ex, frame); return __propagate(_, ex); } finally { __g.frame = oldFrame; } } }

@@ -5,0 +5,0 @@ function __future(fn, args, i){ var done, err, result; var cb = function(e, r){ done = true; err = e, result = r; }; args = Array.prototype.slice.call(args); args[i] = function ___(e, r){ cb(e, r); }; fn.apply(this, args); return function ___(_){ if (done) _.call(this, err, result); else cb = _.bind(this); } .bind(this); }

6

examples/misc/require_error.js

@@ -1,4 +0,4 @@

/*** Generated by streamline 0.1.39 - DO NOT EDIT ***/
var __g=typeof global!=='undefined'?global:window;__g=(__g.__streamline||(__g.__streamline={}));__g.setEF=__g.setEF||function(e,f){e.__frame = e.__frame||f};__g.cbTick = 0;var __nextTick=(typeof process!='undefined'&&typeof process.nextTick=='function')?process.nextTick:function(fn){setTimeout(function(){fn()},0);};var __srcName='./examples/misc/require_error_.js';
function __func(_, __this, __arguments, fn, index, frame, body){ if (!_) { return __future.call(__this, fn, __arguments, index); } frame.file = __srcName; frame.prev = __g.frame; if ((__g.cbTick = ++__g.cbTick % 100) === 0) return __nextTick(__cb(_, frame, -1, 0, body)); __g.frame = frame; try { body(); } catch (e) { __g.setEF(e, frame.prev); __propagate(_, e); } finally { __g.frame = frame.prev; } }
/*** Generated by streamline 0.1.40 - DO NOT EDIT ***/
var __g=typeof global!=='undefined'?global:window;__g=(__g.__streamline||(__g.__streamline={}));__g.setEF=__g.setEF||function(e,f){e.__frame = e.__frame||f};var __srcName='../streamline/examples/misc/require_error_.js';
function __func(_, __this, __arguments, fn, index, frame, body){ if (!_) { return __future.call(__this, fn, __arguments, index); } frame.file = __srcName; frame.prev = __g.frame; __g.frame = frame; try { body(); } catch (e) { __g.setEF(e, frame.prev); __propagate(_, e); } finally { __g.frame = frame.prev; } }
function __cb(_, frame, offset, col, fn){ frame.offset = offset; frame.col = col; var ctx = __g.context; return function ___(err, result){ var oldFrame = __g.frame; __g.frame = frame; __g.context = ctx; try { if (err) { __g.setEF(err, frame); return _(err); } return fn(null, result); } catch (ex) { __g.setEF(ex, frame); return __propagate(_, ex); } finally { __g.frame = oldFrame; } } }

@@ -5,0 +5,0 @@ function __future(fn, args, i){ var done, err, result; var cb = function(e, r){ done = true; err = e, result = r; }; args = Array.prototype.slice.call(args); args[i] = function ___(e, r){ cb(e, r); }; fn.apply(this, args); return function ___(_){ if (done) _.call(this, err, result); else cb = _.bind(this); } .bind(this); }

8

examples/streamlineMe/streamlineMe.js

@@ -157,5 +157,7 @@ var _demo = "\n" +

window.__context = {
errorHandler: function(err) {
error(err.message || err.toString());
window.__streamline = {
context: {
errorHandler: function(err){
error(err.message || err.toString());
}
}

@@ -162,0 +164,0 @@ }

6

examples/streams/googleClient.js

@@ -1,4 +0,4 @@

/*** Generated by streamline 0.1.39 - DO NOT EDIT ***/
var __g=typeof global!=='undefined'?global:window;__g=(__g.__streamline||(__g.__streamline={}));__g.setEF=__g.setEF||function(e,f){e.__frame = e.__frame||f};__g.cbTick = 0;var __nextTick=(typeof process!='undefined'&&typeof process.nextTick=='function')?process.nextTick:function(fn){setTimeout(function(){fn()},0);};var __srcName='./examples/streams/googleClient_.js';
function __func(_, __this, __arguments, fn, index, frame, body){ if (!_) { return __future.call(__this, fn, __arguments, index); } frame.file = __srcName; frame.prev = __g.frame; if ((__g.cbTick = ++__g.cbTick % 100) === 0) return __nextTick(__cb(_, frame, -1, 0, body)); __g.frame = frame; try { body(); } catch (e) { __g.setEF(e, frame.prev); __propagate(_, e); } finally { __g.frame = frame.prev; } }
/*** Generated by streamline 0.1.40 - DO NOT EDIT ***/
var __g=typeof global!=='undefined'?global:window;__g=(__g.__streamline||(__g.__streamline={}));__g.setEF=__g.setEF||function(e,f){e.__frame = e.__frame||f};var __srcName='../streamline/examples/streams/googleClient_.js';
function __func(_, __this, __arguments, fn, index, frame, body){ if (!_) { return __future.call(__this, fn, __arguments, index); } frame.file = __srcName; frame.prev = __g.frame; __g.frame = frame; try { body(); } catch (e) { __g.setEF(e, frame.prev); __propagate(_, e); } finally { __g.frame = frame.prev; } }
function __cb(_, frame, offset, col, fn){ frame.offset = offset; frame.col = col; var ctx = __g.context; return function ___(err, result){ var oldFrame = __g.frame; __g.frame = frame; __g.context = ctx; try { if (err) { __g.setEF(err, frame); return _(err); } return fn(null, result); } catch (ex) { __g.setEF(ex, frame); return __propagate(_, ex); } finally { __g.frame = oldFrame; } } }

@@ -5,0 +5,0 @@ function __future(fn, args, i){ var done, err, result; var cb = function(e, r){ done = true; err = e, result = r; }; args = Array.prototype.slice.call(args); args[i] = function ___(e, r){ cb(e, r); }; fn.apply(this, args); return function ___(_){ if (done) _.call(this, err, result); else cb = _.bind(this); } .bind(this); }

2

lib/compiler/compile.js

@@ -1,2 +0,2 @@

/*** Generated by streamline 0.1.39 - DO NOT EDIT ***/ "use strict"; var __g=typeof global!=='undefined'?global:window;__g=(__g.__streamline||(__g.__streamline={}));__g.setEF=__g.setEF||function(e,f){e.__frame = e.__frame||f};__g.cbTick = 0;var __nextTick=(typeof process!='undefined'&&typeof process.nextTick=='function')?process.nextTick:function(fn){setTimeout(function(){fn()},0);};var __srcName='./lib/compiler/compile_.js'; function __func(_, __this, __arguments, fn, index, frame, body){ if (!_) { return __future.call(__this, fn, __arguments, index); } frame.file = __srcName; frame.prev = __g.frame; if ((__g.cbTick = ++__g.cbTick % 100) === 0) return __nextTick(__cb(_, frame, -1, 0, body)); __g.frame = frame; try { body(); } catch (e) { __g.setEF(e, frame.prev); __propagate(_, e); } finally { __g.frame = frame.prev; } } function __cb(_, frame, offset, col, fn){ frame.offset = offset; frame.col = col; var ctx = __g.context; return function ___(err, result){ var oldFrame = __g.frame; __g.frame = frame; __g.context = ctx; try { if (err) { __g.setEF(err, frame); return _(err); } return fn(null, result); } catch (ex) { __g.setEF(ex, frame); return __propagate(_, ex); } finally { __g.frame = oldFrame; } } } function __future(fn, args, i){ var done, err, result; var cb = function(e, r){ done = true; err = e, result = r; }; args = Array.prototype.slice.call(args); args[i] = function ___(e, r){ cb(e, r); }; fn.apply(this, args); return function ___(_){ if (done) _.call(this, err, result); else cb = _.bind(this); } .bind(this); } function __propagate(_, err){ try { _(err); } catch (ex) { __trap(ex); } } function __trap(err){ if (err) { if (__g.context && __g.context.errorHandler) __g.context.errorHandler(err); else console.error("UNCAUGHT EXCEPTION: " + err.message + "\n" + err.stack); } } function __tryCatch(_, fn){ try { fn(); } catch (e) { try { _(e); } catch (ex) { __trap(ex); } } } var fs = require("fs");
/*** Generated by streamline 0.1.40 - DO NOT EDIT ***/ "use strict"; var __g=typeof global!=='undefined'?global:window;__g=(__g.__streamline||(__g.__streamline={}));__g.setEF=__g.setEF||function(e,f){e.__frame = e.__frame||f};var __srcName='../streamline/lib/compiler/compile_.js'; function __func(_, __this, __arguments, fn, index, frame, body){ if (!_) { return __future.call(__this, fn, __arguments, index); } frame.file = __srcName; frame.prev = __g.frame; __g.frame = frame; try { body(); } catch (e) { __g.setEF(e, frame.prev); __propagate(_, e); } finally { __g.frame = frame.prev; } } function __cb(_, frame, offset, col, fn){ frame.offset = offset; frame.col = col; var ctx = __g.context; return function ___(err, result){ var oldFrame = __g.frame; __g.frame = frame; __g.context = ctx; try { if (err) { __g.setEF(err, frame); return _(err); } return fn(null, result); } catch (ex) { __g.setEF(ex, frame); return __propagate(_, ex); } finally { __g.frame = oldFrame; } } } function __future(fn, args, i){ var done, err, result; var cb = function(e, r){ done = true; err = e, result = r; }; args = Array.prototype.slice.call(args); args[i] = function ___(e, r){ cb(e, r); }; fn.apply(this, args); return function ___(_){ if (done) _.call(this, err, result); else cb = _.bind(this); } .bind(this); } function __propagate(_, err){ try { _(err); } catch (ex) { __trap(ex); } } function __trap(err){ if (err) { if (__g.context && __g.context.errorHandler) __g.context.errorHandler(err); else console.error("UNCAUGHT EXCEPTION: " + err.message + "\n" + err.stack); } } function __tryCatch(_, fn){ try { fn(); } catch (e) { try { _(e); } catch (ex) { __trap(ex); } } } var fs = require("fs");

@@ -3,0 +3,0 @@

65

lib/compiler/transform.js

@@ -988,4 +988,2 @@

frame.prev = __g.frame;
if ((__g.cbTick = ++__g.cbTick % 100) === 0)
return __nextTick(__cb(_, frame, -1, 0, body));

@@ -1012,4 +1010,7 @@ __g.frame = frame;

$decls;
var __frame = { name: $fname, line: $line };
return __func(_, this, arguments, $fn, $index, __frame, function $name() {
var __frame = {
name: $fname,
line: $line
};
return __func(_, this, arguments, $fn, $index, __frame, function $name(){
$body;

@@ -1064,3 +1065,7 @@ _();

CONTINUE: new Template("cb", function _t(){
return __loop();
while (__more) {
__loop();
}
__more = true;
return;
}),

@@ -1070,3 +1075,6 @@ LOOP1: new Template("cb", function _(){

$body;
__loop();
while (__more) {
__loop();
}
__more = true;
}

@@ -1094,6 +1102,12 @@ else {

return (function ___(__break){
var __loop = __nt(_, __frame, function $name(){
var __more;
var __loop = __cb(_, __frame, 0, 0, function $name(){
__more = false;
$loop2
});
__loop();
do {
__loop();
}
while (__more);
__more = true;
})(function $name(){

@@ -1106,6 +1120,12 @@ $tail;

return (function ___(__break){
var __loop = __nt(_, __frame, function $name(){
var __more;
var __loop = __cb(_, __frame, 0, 0, function $name(){
__more = false;
$loop2
});
__loop();
do {
__loop();
}
while (__more);
__more = true;
})(function $name(){

@@ -1497,6 +1517,4 @@ $tail;

"__g=(__g.__streamline||(__g.__streamline={}));" +
"__g.setEF=__g.setEF||function(e,f){e.__frame = e.__frame||f};" +
"__g.cbTick = 0;" +
"var __nextTick=(typeof process!='undefined'&&typeof process.nextTick=='function')?process.nextTick:function(fn){setTimeout(function(){fn()},0);};";
"__g.setEF=__g.setEF||function(e,f){e.__frame = e.__frame||f};";
function __cb(_, frame, offset, col, fn){

@@ -1547,14 +1565,3 @@ frame.offset = offset;

}
// don't go through process.nextTick/setTimeout at every iteration
function __nt(_, frame, fn){
var cb = __cb(_, frame, 0, 0, fn);
return function ___(){
if ((__g.cbTick = ++__g.cbTick % 100) === 0)
__nextTick(cb);
else
cb();
};
}
function __propagate(_, err){

@@ -1691,4 +1698,3 @@ try {

strict = strict ? '"use strict";' + sep : "";
used.__cb = used.__cb || used.__func || used.__nt;
used.__propagate = used.__propagate || used.__nt || used.__func;
used.__propagate = used.__propagate || used.__func;
used.__trap = used.__trap || used.__propagate || used.__tryCatch;

@@ -1702,3 +1708,2 @@ used.__future = used.__future || used.__func || used.__apply;

((!used || used.__future) ? sep + _trim(__future) : "") +
((!used || used.__nt) ? sep + _trim(__nt) : "") +
((!used || used.__propagate) ? sep + _trim(__propagate) : "") +

@@ -1711,3 +1716,3 @@ ((!used || used.__trap) ? sep + _trim(__trap) : "") +

}
exports.version = "0.1.39";
exports.version = "0.1.40";

@@ -1714,0 +1719,0 @@ exports.banner = function(){

6

lib/require/server/depend.js

@@ -1,2 +0,2 @@

/*** Generated by streamline 0.1.39 - DO NOT EDIT ***/ "use strict"; var __g=typeof global!=='undefined'?global:window;__g=(__g.__streamline||(__g.__streamline={}));__g.setEF=__g.setEF||function(e,f){e.__frame = e.__frame||f};__g.cbTick = 0;var __nextTick=(typeof process!='undefined'&&typeof process.nextTick=='function')?process.nextTick:function(fn){setTimeout(function(){fn()},0);};var __srcName='./lib/require/server/depend_.js'; function __func(_, __this, __arguments, fn, index, frame, body){ if (!_) { return __future.call(__this, fn, __arguments, index); } frame.file = __srcName; frame.prev = __g.frame; if ((__g.cbTick = ++__g.cbTick % 100) === 0) return __nextTick(__cb(_, frame, -1, 0, body)); __g.frame = frame; try { body(); } catch (e) { __g.setEF(e, frame.prev); __propagate(_, e); } finally { __g.frame = frame.prev; } } function __cb(_, frame, offset, col, fn){ frame.offset = offset; frame.col = col; var ctx = __g.context; return function ___(err, result){ var oldFrame = __g.frame; __g.frame = frame; __g.context = ctx; try { if (err) { __g.setEF(err, frame); return _(err); } return fn(null, result); } catch (ex) { __g.setEF(ex, frame); return __propagate(_, ex); } finally { __g.frame = oldFrame; } } } function __future(fn, args, i){ var done, err, result; var cb = function(e, r){ done = true; err = e, result = r; }; args = Array.prototype.slice.call(args); args[i] = function ___(e, r){ cb(e, r); }; fn.apply(this, args); return function ___(_){ if (done) _.call(this, err, result); else cb = _.bind(this); } .bind(this); } function __nt(_, frame, fn){ var cb = __cb(_, frame, 0, 0, fn); return function ___(){ if ((__g.cbTick = ++__g.cbTick % 100) === 0) __nextTick(cb); else cb(); }; } function __propagate(_, err){ try { _(err); } catch (ex) { __trap(ex); } } function __trap(err){ if (err) { if (__g.context && __g.context.errorHandler) __g.context.errorHandler(err); else console.error("UNCAUGHT EXCEPTION: " + err.message + "\n" + err.stack); } } var fs = require("fs");
/*** Generated by streamline 0.1.40 - DO NOT EDIT ***/ "use strict"; var __g=typeof global!=='undefined'?global:window;__g=(__g.__streamline||(__g.__streamline={}));__g.setEF=__g.setEF||function(e,f){e.__frame = e.__frame||f};var __srcName='../streamline/lib/require/server/depend_.js'; function __func(_, __this, __arguments, fn, index, frame, body){ if (!_) { return __future.call(__this, fn, __arguments, index); } frame.file = __srcName; frame.prev = __g.frame; __g.frame = frame; try { body(); } catch (e) { __g.setEF(e, frame.prev); __propagate(_, e); } finally { __g.frame = frame.prev; } } function __cb(_, frame, offset, col, fn){ frame.offset = offset; frame.col = col; var ctx = __g.context; return function ___(err, result){ var oldFrame = __g.frame; __g.frame = frame; __g.context = ctx; try { if (err) { __g.setEF(err, frame); return _(err); } return fn(null, result); } catch (ex) { __g.setEF(ex, frame); return __propagate(_, ex); } finally { __g.frame = oldFrame; } } } function __future(fn, args, i){ var done, err, result; var cb = function(e, r){ done = true; err = e, result = r; }; args = Array.prototype.slice.call(args); args[i] = function ___(e, r){ cb(e, r); }; fn.apply(this, args); return function ___(_){ if (done) _.call(this, err, result); else cb = _.bind(this); } .bind(this); } function __propagate(_, err){ try { _(err); } catch (ex) { __trap(ex); } } function __trap(err){ if (err) { if (__g.context && __g.context.errorHandler) __g.context.errorHandler(err); else console.error("UNCAUGHT EXCEPTION: " + err.message + "\n" + err.stack); } } var fs = require("fs");

@@ -27,6 +27,6 @@

return _(null, modulesDir); } ;
dir = __dirname; var __3 = false; return (function ___(__break) { var __loop = __nt(_, __frame, function __$_findModulesDir() { if (__3) { dir = dir.substring(0, dir.lastIndexOf("/")); } else { __3 = true; } ; var __2 = (dir.length > 0); if (__2) {
dir = __dirname; var __3 = false; return (function ___(__break) { var __more; var __loop = __cb(_, __frame, 0, 0, function __$_findModulesDir() { __more = false; if (__3) { dir = dir.substring(0, dir.lastIndexOf("/")); } else { __3 = true; } ; var __2 = (dir.length > 0); if (__2) {
return _exists(__cb(_, __frame, 4, 6, function ___(__0, __1) { return (function __$_findModulesDir(__then) { if (__1) {
modulesDir = (dir + "/node_modules");
return _(null, modulesDir); } else { __then(); } ; })(__loop); }), (dir + "/node_modules")); } else { __break(); } ; }); __loop(); })(function __$_findModulesDir() {
return _(null, modulesDir); } else { __then(); } ; })(function __$_findModulesDir() { while (__more) { __loop(); }; __more = true; }); }), (dir + "/node_modules")); } else { __break(); } ; }); do { __loop(); } while (__more); __more = true; })(function __$_findModulesDir() {

@@ -33,0 +33,0 @@

2

lib/require/server/require.js

@@ -1,2 +0,2 @@

/*** Generated by streamline 0.1.39 - DO NOT EDIT ***/ "use strict"; var __g=typeof global!=='undefined'?global:window;__g=(__g.__streamline||(__g.__streamline={}));__g.setEF=__g.setEF||function(e,f){e.__frame = e.__frame||f};__g.cbTick = 0;var __nextTick=(typeof process!='undefined'&&typeof process.nextTick=='function')?process.nextTick:function(fn){setTimeout(function(){fn()},0);};var __srcName='./lib/require/server/require_.js'; function __func(_, __this, __arguments, fn, index, frame, body){ if (!_) { return __future.call(__this, fn, __arguments, index); } frame.file = __srcName; frame.prev = __g.frame; if ((__g.cbTick = ++__g.cbTick % 100) === 0) return __nextTick(__cb(_, frame, -1, 0, body)); __g.frame = frame; try { body(); } catch (e) { __g.setEF(e, frame.prev); __propagate(_, e); } finally { __g.frame = frame.prev; } } function __cb(_, frame, offset, col, fn){ frame.offset = offset; frame.col = col; var ctx = __g.context; return function ___(err, result){ var oldFrame = __g.frame; __g.frame = frame; __g.context = ctx; try { if (err) { __g.setEF(err, frame); return _(err); } return fn(null, result); } catch (ex) { __g.setEF(ex, frame); return __propagate(_, ex); } finally { __g.frame = oldFrame; } } } function __future(fn, args, i){ var done, err, result; var cb = function(e, r){ done = true; err = e, result = r; }; args = Array.prototype.slice.call(args); args[i] = function ___(e, r){ cb(e, r); }; fn.apply(this, args); return function ___(_){ if (done) _.call(this, err, result); else cb = _.bind(this); } .bind(this); } function __propagate(_, err){ try { _(err); } catch (ex) { __trap(ex); } } function __trap(err){ if (err) { if (__g.context && __g.context.errorHandler) __g.context.errorHandler(err); else console.error("UNCAUGHT EXCEPTION: " + err.message + "\n" + err.stack); } } function __tryCatch(_, fn){ try { fn(); } catch (e) { try { _(e); } catch (ex) { __trap(ex); } } } var fs = require("fs");
/*** Generated by streamline 0.1.40 - DO NOT EDIT ***/ "use strict"; var __g=typeof global!=='undefined'?global:window;__g=(__g.__streamline||(__g.__streamline={}));__g.setEF=__g.setEF||function(e,f){e.__frame = e.__frame||f};var __srcName='../streamline/lib/require/server/require_.js'; function __func(_, __this, __arguments, fn, index, frame, body){ if (!_) { return __future.call(__this, fn, __arguments, index); } frame.file = __srcName; frame.prev = __g.frame; __g.frame = frame; try { body(); } catch (e) { __g.setEF(e, frame.prev); __propagate(_, e); } finally { __g.frame = frame.prev; } } function __cb(_, frame, offset, col, fn){ frame.offset = offset; frame.col = col; var ctx = __g.context; return function ___(err, result){ var oldFrame = __g.frame; __g.frame = frame; __g.context = ctx; try { if (err) { __g.setEF(err, frame); return _(err); } return fn(null, result); } catch (ex) { __g.setEF(ex, frame); return __propagate(_, ex); } finally { __g.frame = oldFrame; } } } function __future(fn, args, i){ var done, err, result; var cb = function(e, r){ done = true; err = e, result = r; }; args = Array.prototype.slice.call(args); args[i] = function ___(e, r){ cb(e, r); }; fn.apply(this, args); return function ___(_){ if (done) _.call(this, err, result); else cb = _.bind(this); } .bind(this); } function __propagate(_, err){ try { _(err); } catch (ex) { __trap(ex); } } function __trap(err){ if (err) { if (__g.context && __g.context.errorHandler) __g.context.errorHandler(err); else console.error("UNCAUGHT EXCEPTION: " + err.message + "\n" + err.stack); } } function __tryCatch(_, fn){ try { fn(); } catch (e) { try { _(e); } catch (ex) { __trap(ex); } } } var fs = require("fs");

@@ -3,0 +3,0 @@

2

lib/streams/client/streams.js

@@ -1,2 +0,2 @@

/*** Generated by streamline 0.1.39 - DO NOT EDIT ***/ "use strict"; var __g=typeof global!=='undefined'?global:window;__g=(__g.__streamline||(__g.__streamline={}));__g.setEF=__g.setEF||function(e,f){e.__frame = e.__frame||f};__g.cbTick = 0;var __nextTick=(typeof process!='undefined'&&typeof process.nextTick=='function')?process.nextTick:function(fn){setTimeout(function(){fn()},0);};var __srcName='./lib/streams/client/streams_.js'; function __func(_, __this, __arguments, fn, index, frame, body){ if (!_) { return __future.call(__this, fn, __arguments, index); } frame.file = __srcName; frame.prev = __g.frame; if ((__g.cbTick = ++__g.cbTick % 100) === 0) return __nextTick(__cb(_, frame, -1, 0, body)); __g.frame = frame; try { body(); } catch (e) { __g.setEF(e, frame.prev); __propagate(_, e); } finally { __g.frame = frame.prev; } } function __cb(_, frame, offset, col, fn){ frame.offset = offset; frame.col = col; var ctx = __g.context; return function ___(err, result){ var oldFrame = __g.frame; __g.frame = frame; __g.context = ctx; try { if (err) { __g.setEF(err, frame); return _(err); } return fn(null, result); } catch (ex) { __g.setEF(ex, frame); return __propagate(_, ex); } finally { __g.frame = oldFrame; } } } function __future(fn, args, i){ var done, err, result; var cb = function(e, r){ done = true; err = e, result = r; }; args = Array.prototype.slice.call(args); args[i] = function ___(e, r){ cb(e, r); }; fn.apply(this, args); return function ___(_){ if (done) _.call(this, err, result); else cb = _.bind(this); } .bind(this); } function __propagate(_, err){ try { _(err); } catch (ex) { __trap(ex); } } function __trap(err){ if (err) { if (__g.context && __g.context.errorHandler) __g.context.errorHandler(err); else console.error("UNCAUGHT EXCEPTION: " + err.message + "\n" + err.stack); } } function DataBuffer(options) {
/*** Generated by streamline 0.1.40 - DO NOT EDIT ***/ "use strict"; var __g=typeof global!=='undefined'?global:window;__g=(__g.__streamline||(__g.__streamline={}));__g.setEF=__g.setEF||function(e,f){e.__frame = e.__frame||f};var __srcName='../streamline/lib/streams/client/streams_.js'; function __func(_, __this, __arguments, fn, index, frame, body){ if (!_) { return __future.call(__this, fn, __arguments, index); } frame.file = __srcName; frame.prev = __g.frame; __g.frame = frame; try { body(); } catch (e) { __g.setEF(e, frame.prev); __propagate(_, e); } finally { __g.frame = frame.prev; } } function __cb(_, frame, offset, col, fn){ frame.offset = offset; frame.col = col; var ctx = __g.context; return function ___(err, result){ var oldFrame = __g.frame; __g.frame = frame; __g.context = ctx; try { if (err) { __g.setEF(err, frame); return _(err); } return fn(null, result); } catch (ex) { __g.setEF(ex, frame); return __propagate(_, ex); } finally { __g.frame = oldFrame; } } } function __future(fn, args, i){ var done, err, result; var cb = function(e, r){ done = true; err = e, result = r; }; args = Array.prototype.slice.call(args); args[i] = function ___(e, r){ cb(e, r); }; fn.apply(this, args); return function ___(_){ if (done) _.call(this, err, result); else cb = _.bind(this); } .bind(this); } function __propagate(_, err){ try { _(err); } catch (ex) { __trap(ex); } } function __trap(err){ if (err) { if (__g.context && __g.context.errorHandler) __g.context.errorHandler(err); else console.error("UNCAUGHT EXCEPTION: " + err.message + "\n" + err.stack); } } function DataBuffer(options) {

@@ -3,0 +3,0 @@

2

lib/streams/jsonRequest.js

@@ -1,2 +0,2 @@

/*** Generated by streamline 0.1.39 - DO NOT EDIT ***/ "use strict"; var __g=typeof global!=='undefined'?global:window;__g=(__g.__streamline||(__g.__streamline={}));__g.setEF=__g.setEF||function(e,f){e.__frame = e.__frame||f};__g.cbTick = 0;var __nextTick=(typeof process!='undefined'&&typeof process.nextTick=='function')?process.nextTick:function(fn){setTimeout(function(){fn()},0);};var __srcName='./lib/streams/jsonRequest_.js'; function __func(_, __this, __arguments, fn, index, frame, body){ if (!_) { return __future.call(__this, fn, __arguments, index); } frame.file = __srcName; frame.prev = __g.frame; if ((__g.cbTick = ++__g.cbTick % 100) === 0) return __nextTick(__cb(_, frame, -1, 0, body)); __g.frame = frame; try { body(); } catch (e) { __g.setEF(e, frame.prev); __propagate(_, e); } finally { __g.frame = frame.prev; } } function __cb(_, frame, offset, col, fn){ frame.offset = offset; frame.col = col; var ctx = __g.context; return function ___(err, result){ var oldFrame = __g.frame; __g.frame = frame; __g.context = ctx; try { if (err) { __g.setEF(err, frame); return _(err); } return fn(null, result); } catch (ex) { __g.setEF(ex, frame); return __propagate(_, ex); } finally { __g.frame = oldFrame; } } } function __future(fn, args, i){ var done, err, result; var cb = function(e, r){ done = true; err = e, result = r; }; args = Array.prototype.slice.call(args); args[i] = function ___(e, r){ cb(e, r); }; fn.apply(this, args); return function ___(_){ if (done) _.call(this, err, result); else cb = _.bind(this); } .bind(this); } function __propagate(_, err){ try { _(err); } catch (ex) { __trap(ex); } } function __trap(err){ if (err) { if (__g.context && __g.context.errorHandler) __g.context.errorHandler(err); else console.error("UNCAUGHT EXCEPTION: " + err.message + "\n" + err.stack); } } var streams = require("./streams");
/*** Generated by streamline 0.1.40 - DO NOT EDIT ***/ "use strict"; var __g=typeof global!=='undefined'?global:window;__g=(__g.__streamline||(__g.__streamline={}));__g.setEF=__g.setEF||function(e,f){e.__frame = e.__frame||f};var __srcName='../streamline/lib/streams/jsonRequest_.js'; function __func(_, __this, __arguments, fn, index, frame, body){ if (!_) { return __future.call(__this, fn, __arguments, index); } frame.file = __srcName; frame.prev = __g.frame; __g.frame = frame; try { body(); } catch (e) { __g.setEF(e, frame.prev); __propagate(_, e); } finally { __g.frame = frame.prev; } } function __cb(_, frame, offset, col, fn){ frame.offset = offset; frame.col = col; var ctx = __g.context; return function ___(err, result){ var oldFrame = __g.frame; __g.frame = frame; __g.context = ctx; try { if (err) { __g.setEF(err, frame); return _(err); } return fn(null, result); } catch (ex) { __g.setEF(ex, frame); return __propagate(_, ex); } finally { __g.frame = oldFrame; } } } function __future(fn, args, i){ var done, err, result; var cb = function(e, r){ done = true; err = e, result = r; }; args = Array.prototype.slice.call(args); args[i] = function ___(e, r){ cb(e, r); }; fn.apply(this, args); return function ___(_){ if (done) _.call(this, err, result); else cb = _.bind(this); } .bind(this); } function __propagate(_, err){ try { _(err); } catch (ex) { __trap(ex); } } function __trap(err){ if (err) { if (__g.context && __g.context.errorHandler) __g.context.errorHandler(err); else console.error("UNCAUGHT EXCEPTION: " + err.message + "\n" + err.stack); } } var streams = require("./streams");

@@ -3,0 +3,0 @@

6

lib/streams/readers.js

@@ -1,2 +0,2 @@

/*** Generated by streamline 0.1.39 - DO NOT EDIT ***/ "use strict"; var __g=typeof global!=='undefined'?global:window;__g=(__g.__streamline||(__g.__streamline={}));__g.setEF=__g.setEF||function(e,f){e.__frame = e.__frame||f};__g.cbTick = 0;var __nextTick=(typeof process!='undefined'&&typeof process.nextTick=='function')?process.nextTick:function(fn){setTimeout(function(){fn()},0);};var __srcName='./lib/streams/readers_.js'; function __func(_, __this, __arguments, fn, index, frame, body){ if (!_) { return __future.call(__this, fn, __arguments, index); } frame.file = __srcName; frame.prev = __g.frame; if ((__g.cbTick = ++__g.cbTick % 100) === 0) return __nextTick(__cb(_, frame, -1, 0, body)); __g.frame = frame; try { body(); } catch (e) { __g.setEF(e, frame.prev); __propagate(_, e); } finally { __g.frame = frame.prev; } } function __cb(_, frame, offset, col, fn){ frame.offset = offset; frame.col = col; var ctx = __g.context; return function ___(err, result){ var oldFrame = __g.frame; __g.frame = frame; __g.context = ctx; try { if (err) { __g.setEF(err, frame); return _(err); } return fn(null, result); } catch (ex) { __g.setEF(ex, frame); return __propagate(_, ex); } finally { __g.frame = oldFrame; } } } function __future(fn, args, i){ var done, err, result; var cb = function(e, r){ done = true; err = e, result = r; }; args = Array.prototype.slice.call(args); args[i] = function ___(e, r){ cb(e, r); }; fn.apply(this, args); return function ___(_){ if (done) _.call(this, err, result); else cb = _.bind(this); } .bind(this); } function __nt(_, frame, fn){ var cb = __cb(_, frame, 0, 0, fn); return function ___(){ if ((__g.cbTick = ++__g.cbTick % 100) === 0) __nextTick(cb); else cb(); }; } function __propagate(_, err){ try { _(err); } catch (ex) { __trap(ex); } } function __trap(err){ if (err) { if (__g.context && __g.context.errorHandler) __g.context.errorHandler(err); else console.error("UNCAUGHT EXCEPTION: " + err.message + "\n" + err.stack); } } var streams = require("./streams");
/*** Generated by streamline 0.1.40 - DO NOT EDIT ***/ "use strict"; var __g=typeof global!=='undefined'?global:window;__g=(__g.__streamline||(__g.__streamline={}));__g.setEF=__g.setEF||function(e,f){e.__frame = e.__frame||f};var __srcName='../streamline/lib/streams/readers_.js'; function __func(_, __this, __arguments, fn, index, frame, body){ if (!_) { return __future.call(__this, fn, __arguments, index); } frame.file = __srcName; frame.prev = __g.frame; __g.frame = frame; try { body(); } catch (e) { __g.setEF(e, frame.prev); __propagate(_, e); } finally { __g.frame = frame.prev; } } function __cb(_, frame, offset, col, fn){ frame.offset = offset; frame.col = col; var ctx = __g.context; return function ___(err, result){ var oldFrame = __g.frame; __g.frame = frame; __g.context = ctx; try { if (err) { __g.setEF(err, frame); return _(err); } return fn(null, result); } catch (ex) { __g.setEF(ex, frame); return __propagate(_, ex); } finally { __g.frame = oldFrame; } } } function __future(fn, args, i){ var done, err, result; var cb = function(e, r){ done = true; err = e, result = r; }; args = Array.prototype.slice.call(args); args[i] = function ___(e, r){ cb(e, r); }; fn.apply(this, args); return function ___(_){ if (done) _.call(this, err, result); else cb = _.bind(this); } .bind(this); } function __propagate(_, err){ try { _(err); } catch (ex) { __trap(ex); } } function __trap(err){ if (err) { if (__g.context && __g.context.errorHandler) __g.context.errorHandler(err); else console.error("UNCAUGHT EXCEPTION: " + err.message + "\n" + err.stack); } } var streams = require("./streams");

@@ -30,3 +30,3 @@

chunks = [];
len = options.defaultSize; return (function ___(__break) { var __loop = __nt(_, __frame, function __$readItem__1() {
len = options.defaultSize; return (function ___(__break) { var __more; var __loop = __cb(_, __frame, 0, 0, function __$readItem__1() { __more = false;
var __2 = stream; if (__2) {

@@ -46,3 +46,3 @@ return stream.read(__cb(_, __frame, 4, 15, function ___(__0, __1) { chunk = __1;

else {
return _(new Error(((("missing boundary:" + boundary) + " in: ") + chunk))); } ; } ; } ; __loop(); }), (len + boundary.length)); } else { __break(); } ; }); __loop(); })(function __$readItem__1() {
return _(new Error(((("missing boundary:" + boundary) + " in: ") + chunk))); } ; } ; } ; while (__more) { __loop(); }; __more = true; }), (len + boundary.length)); } else { __break(); } ; }); do { __loop(); } while (__more); __more = true; })(function __$readItem__1() {

@@ -49,0 +49,0 @@

2

lib/streams/server/httpHelper.js

@@ -1,2 +0,2 @@

/*** Generated by streamline 0.1.39 - DO NOT EDIT ***/ "use strict"; var __g=typeof global!=='undefined'?global:window;__g=(__g.__streamline||(__g.__streamline={}));__g.setEF=__g.setEF||function(e,f){e.__frame = e.__frame||f};__g.cbTick = 0;var __nextTick=(typeof process!='undefined'&&typeof process.nextTick=='function')?process.nextTick:function(fn){setTimeout(function(){fn()},0);};var __srcName='./lib/streams/server/httpHelper_.js'; function __func(_, __this, __arguments, fn, index, frame, body){ if (!_) { return __future.call(__this, fn, __arguments, index); } frame.file = __srcName; frame.prev = __g.frame; if ((__g.cbTick = ++__g.cbTick % 100) === 0) return __nextTick(__cb(_, frame, -1, 0, body)); __g.frame = frame; try { body(); } catch (e) { __g.setEF(e, frame.prev); __propagate(_, e); } finally { __g.frame = frame.prev; } } function __cb(_, frame, offset, col, fn){ frame.offset = offset; frame.col = col; var ctx = __g.context; return function ___(err, result){ var oldFrame = __g.frame; __g.frame = frame; __g.context = ctx; try { if (err) { __g.setEF(err, frame); return _(err); } return fn(null, result); } catch (ex) { __g.setEF(ex, frame); return __propagate(_, ex); } finally { __g.frame = oldFrame; } } } function __future(fn, args, i){ var done, err, result; var cb = function(e, r){ done = true; err = e, result = r; }; args = Array.prototype.slice.call(args); args[i] = function ___(e, r){ cb(e, r); }; fn.apply(this, args); return function ___(_){ if (done) _.call(this, err, result); else cb = _.bind(this); } .bind(this); } function __propagate(_, err){ try { _(err); } catch (ex) { __trap(ex); } } function __trap(err){ if (err) { if (__g.context && __g.context.errorHandler) __g.context.errorHandler(err); else console.error("UNCAUGHT EXCEPTION: " + err.message + "\n" + err.stack); } } var urlHelper = require("streamline/lib/util/url");
/*** Generated by streamline 0.1.40 - DO NOT EDIT ***/ "use strict"; var __g=typeof global!=='undefined'?global:window;__g=(__g.__streamline||(__g.__streamline={}));__g.setEF=__g.setEF||function(e,f){e.__frame = e.__frame||f};var __srcName='../streamline/lib/streams/server/httpHelper_.js'; function __func(_, __this, __arguments, fn, index, frame, body){ if (!_) { return __future.call(__this, fn, __arguments, index); } frame.file = __srcName; frame.prev = __g.frame; __g.frame = frame; try { body(); } catch (e) { __g.setEF(e, frame.prev); __propagate(_, e); } finally { __g.frame = frame.prev; } } function __cb(_, frame, offset, col, fn){ frame.offset = offset; frame.col = col; var ctx = __g.context; return function ___(err, result){ var oldFrame = __g.frame; __g.frame = frame; __g.context = ctx; try { if (err) { __g.setEF(err, frame); return _(err); } return fn(null, result); } catch (ex) { __g.setEF(ex, frame); return __propagate(_, ex); } finally { __g.frame = oldFrame; } } } function __future(fn, args, i){ var done, err, result; var cb = function(e, r){ done = true; err = e, result = r; }; args = Array.prototype.slice.call(args); args[i] = function ___(e, r){ cb(e, r); }; fn.apply(this, args); return function ___(_){ if (done) _.call(this, err, result); else cb = _.bind(this); } .bind(this); } function __propagate(_, err){ try { _(err); } catch (ex) { __trap(ex); } } function __trap(err){ if (err) { if (__g.context && __g.context.errorHandler) __g.context.errorHandler(err); else console.error("UNCAUGHT EXCEPTION: " + err.message + "\n" + err.stack); } } var urlHelper = require("streamline/lib/util/url");

@@ -3,0 +3,0 @@

6

lib/streams/server/streams.js

@@ -1,2 +0,2 @@

/*** Generated by streamline 0.1.39 - DO NOT EDIT ***/ "use strict"; var __g=typeof global!=='undefined'?global:window;__g=(__g.__streamline||(__g.__streamline={}));__g.setEF=__g.setEF||function(e,f){e.__frame = e.__frame||f};__g.cbTick = 0;var __nextTick=(typeof process!='undefined'&&typeof process.nextTick=='function')?process.nextTick:function(fn){setTimeout(function(){fn()},0);};var __srcName='./lib/streams/server/streams_.js'; function __func(_, __this, __arguments, fn, index, frame, body){ if (!_) { return __future.call(__this, fn, __arguments, index); } frame.file = __srcName; frame.prev = __g.frame; if ((__g.cbTick = ++__g.cbTick % 100) === 0) return __nextTick(__cb(_, frame, -1, 0, body)); __g.frame = frame; try { body(); } catch (e) { __g.setEF(e, frame.prev); __propagate(_, e); } finally { __g.frame = frame.prev; } } function __cb(_, frame, offset, col, fn){ frame.offset = offset; frame.col = col; var ctx = __g.context; return function ___(err, result){ var oldFrame = __g.frame; __g.frame = frame; __g.context = ctx; try { if (err) { __g.setEF(err, frame); return _(err); } return fn(null, result); } catch (ex) { __g.setEF(ex, frame); return __propagate(_, ex); } finally { __g.frame = oldFrame; } } } function __future(fn, args, i){ var done, err, result; var cb = function(e, r){ done = true; err = e, result = r; }; args = Array.prototype.slice.call(args); args[i] = function ___(e, r){ cb(e, r); }; fn.apply(this, args); return function ___(_){ if (done) _.call(this, err, result); else cb = _.bind(this); } .bind(this); } function __nt(_, frame, fn){ var cb = __cb(_, frame, 0, 0, fn); return function ___(){ if ((__g.cbTick = ++__g.cbTick % 100) === 0) __nextTick(cb); else cb(); }; } function __propagate(_, err){ try { _(err); } catch (ex) { __trap(ex); } } function __trap(err){ if (err) { if (__g.context && __g.context.errorHandler) __g.context.errorHandler(err); else console.error("UNCAUGHT EXCEPTION: " + err.message + "\n" + err.stack); } } var parseUrl = require("url").parse;
/*** Generated by streamline 0.1.40 - DO NOT EDIT ***/ "use strict"; var __g=typeof global!=='undefined'?global:window;__g=(__g.__streamline||(__g.__streamline={}));__g.setEF=__g.setEF||function(e,f){e.__frame = e.__frame||f};var __srcName='../streamline/lib/streams/server/streams_.js'; function __func(_, __this, __arguments, fn, index, frame, body){ if (!_) { return __future.call(__this, fn, __arguments, index); } frame.file = __srcName; frame.prev = __g.frame; __g.frame = frame; try { body(); } catch (e) { __g.setEF(e, frame.prev); __propagate(_, e); } finally { __g.frame = frame.prev; } } function __cb(_, frame, offset, col, fn){ frame.offset = offset; frame.col = col; var ctx = __g.context; return function ___(err, result){ var oldFrame = __g.frame; __g.frame = frame; __g.context = ctx; try { if (err) { __g.setEF(err, frame); return _(err); } return fn(null, result); } catch (ex) { __g.setEF(ex, frame); return __propagate(_, ex); } finally { __g.frame = oldFrame; } } } function __future(fn, args, i){ var done, err, result; var cb = function(e, r){ done = true; err = e, result = r; }; args = Array.prototype.slice.call(args); args[i] = function ___(e, r){ cb(e, r); }; fn.apply(this, args); return function ___(_){ if (done) _.call(this, err, result); else cb = _.bind(this); } .bind(this); } function __propagate(_, err){ try { _(err); } catch (ex) { __trap(ex); } } function __trap(err){ if (err) { if (__g.context && __g.context.errorHandler) __g.context.errorHandler(err); else console.error("UNCAUGHT EXCEPTION: " + err.message + "\n" + err.stack); } } var parseUrl = require("url").parse;

@@ -247,3 +247,3 @@

return _(null, (_encoding ? "" : new Buffer(0))); } ;
chunks = []; total = 0; return (function ___(__break) { var __loop = __nt(_, __frame, function __$read__1() {
chunks = []; total = 0; return (function ___(__break) { var __more; var __loop = __cb(_, __frame, 0, 0, function __$read__1() { __more = false;
var __4 = (total < len); if (__4) {

@@ -259,3 +259,3 @@ return readChunk(__cb(_, __frame, 11, 15, function ___(__0, __2) { chunk = __2;

__this.unread(chunk.slice((len - total)));
total = len; } ; __loop(); })); } else { __break(); } ; }); __loop(); })(function __$read__1() {
total = len; } ; while (__more) { __loop(); }; __more = true; })); } else { __break(); } ; }); do { __loop(); } while (__more); __more = true; })(function __$read__1() {

@@ -262,0 +262,0 @@

2

lib/streams/streams.js

@@ -1,2 +0,2 @@

/*** Generated by streamline 0.1.39 - DO NOT EDIT ***/ "use strict"; var __g=typeof global!=='undefined'?global:window;__g=(__g.__streamline||(__g.__streamline={}));__g.setEF=__g.setEF||function(e,f){e.__frame = e.__frame||f};__g.cbTick = 0;var __nextTick=(typeof process!='undefined'&&typeof process.nextTick=='function')?process.nextTick:function(fn){setTimeout(function(){fn()},0);};var __srcName='./lib/streams/streams_.js'; function copy(src, dst) {
/*** Generated by streamline 0.1.40 - DO NOT EDIT ***/ "use strict"; var __g=typeof global!=='undefined'?global:window;__g=(__g.__streamline||(__g.__streamline={}));__g.setEF=__g.setEF||function(e,f){e.__frame = e.__frame||f};var __srcName='../streamline/lib/streams/streams_.js'; function copy(src, dst) {

@@ -3,0 +3,0 @@

6

lib/tools/docTool.js

@@ -1,2 +0,2 @@

/*** Generated by streamline 0.1.39 - DO NOT EDIT ***/ var __g=typeof global!=='undefined'?global:window;__g=(__g.__streamline||(__g.__streamline={}));__g.setEF=__g.setEF||function(e,f){e.__frame = e.__frame||f};__g.cbTick = 0;var __nextTick=(typeof process!='undefined'&&typeof process.nextTick=='function')?process.nextTick:function(fn){setTimeout(function(){fn()},0);};var __srcName='./lib/tools/docTool_.js'; function __func(_, __this, __arguments, fn, index, frame, body){ if (!_) { return __future.call(__this, fn, __arguments, index); } frame.file = __srcName; frame.prev = __g.frame; if ((__g.cbTick = ++__g.cbTick % 100) === 0) return __nextTick(__cb(_, frame, -1, 0, body)); __g.frame = frame; try { body(); } catch (e) { __g.setEF(e, frame.prev); __propagate(_, e); } finally { __g.frame = frame.prev; } } function __cb(_, frame, offset, col, fn){ frame.offset = offset; frame.col = col; var ctx = __g.context; return function ___(err, result){ var oldFrame = __g.frame; __g.frame = frame; __g.context = ctx; try { if (err) { __g.setEF(err, frame); return _(err); } return fn(null, result); } catch (ex) { __g.setEF(ex, frame); return __propagate(_, ex); } finally { __g.frame = oldFrame; } } } function __future(fn, args, i){ var done, err, result; var cb = function(e, r){ done = true; err = e, result = r; }; args = Array.prototype.slice.call(args); args[i] = function ___(e, r){ cb(e, r); }; fn.apply(this, args); return function ___(_){ if (done) _.call(this, err, result); else cb = _.bind(this); } .bind(this); } function __nt(_, frame, fn){ var cb = __cb(_, frame, 0, 0, fn); return function ___(){ if ((__g.cbTick = ++__g.cbTick % 100) === 0) __nextTick(cb); else cb(); }; } function __propagate(_, err){ try { _(err); } catch (ex) { __trap(ex); } } function __trap(err){ if (err) { if (__g.context && __g.context.errorHandler) __g.context.errorHandler(err); else console.error("UNCAUGHT EXCEPTION: " + err.message + "\n" + err.stack); } } (function main(_) { var fs, fsp; var __frame = { name: "main", line: 1 }; return __func(_, this, arguments, main, 0, __frame, function __$main() {
/*** Generated by streamline 0.1.40 - DO NOT EDIT ***/ var __g=typeof global!=='undefined'?global:window;__g=(__g.__streamline||(__g.__streamline={}));__g.setEF=__g.setEF||function(e,f){e.__frame = e.__frame||f};var __srcName='../streamline/lib/tools/docTool_.js'; function __func(_, __this, __arguments, fn, index, frame, body){ if (!_) { return __future.call(__this, fn, __arguments, index); } frame.file = __srcName; frame.prev = __g.frame; __g.frame = frame; try { body(); } catch (e) { __g.setEF(e, frame.prev); __propagate(_, e); } finally { __g.frame = frame.prev; } } function __cb(_, frame, offset, col, fn){ frame.offset = offset; frame.col = col; var ctx = __g.context; return function ___(err, result){ var oldFrame = __g.frame; __g.frame = frame; __g.context = ctx; try { if (err) { __g.setEF(err, frame); return _(err); } return fn(null, result); } catch (ex) { __g.setEF(ex, frame); return __propagate(_, ex); } finally { __g.frame = oldFrame; } } } function __future(fn, args, i){ var done, err, result; var cb = function(e, r){ done = true; err = e, result = r; }; args = Array.prototype.slice.call(args); args[i] = function ___(e, r){ cb(e, r); }; fn.apply(this, args); return function ___(_){ if (done) _.call(this, err, result); else cb = _.bind(this); } .bind(this); } function __propagate(_, err){ try { _(err); } catch (ex) { __trap(ex); } } function __trap(err){ if (err) { if (__g.context && __g.context.errorHandler) __g.context.errorHandler(err); else console.error("UNCAUGHT EXCEPTION: " + err.message + "\n" + err.stack); } } (function main(_) { var fs, fsp; var __frame = { name: "main", line: 1 }; return __func(_, this, arguments, main, 0, __frame, function __$main() {

@@ -58,4 +58,4 @@

return fs.readdir(path, __cb(_, __frame, 24, 15, function ___(__0, __3) { files = __3;
i = 0; var __9 = false; return (function ___(__break) { var __loop = __nt(_, __frame, function __$_generate() { if (__9) { i++; } else { __9 = true; } ; var __8 = (i < files.length); if (__8) {
return _generate(__cb(_, __frame, 26, 11, function ___(__0, __4) { doc += __4; __loop(); }), ((path + "/") + files[i])); } else { __break(); } ; }); __loop(); })(function __$_generate() { return (function __$_generate(__then) {
i = 0; var __9 = false; return (function ___(__break) { var __more; var __loop = __cb(_, __frame, 0, 0, function __$_generate() { __more = false; if (__9) { i++; } else { __9 = true; } ; var __8 = (i < files.length); if (__8) {
return _generate(__cb(_, __frame, 26, 11, function ___(__0, __4) { doc += __4; while (__more) { __loop(); }; __more = true; }), ((path + "/") + files[i])); } else { __break(); } ; }); do { __loop(); } while (__more); __more = true; })(function __$_generate() { return (function __$_generate(__then) {

@@ -62,0 +62,0 @@ if ((isPackage && doc)) {

34

lib/util/flows.js

@@ -1,2 +0,2 @@

/*** Generated by streamline 0.1.39 - DO NOT EDIT ***/ var __g=typeof global!=='undefined'?global:window;__g=(__g.__streamline||(__g.__streamline={}));__g.setEF=__g.setEF||function(e,f){e.__frame = e.__frame||f};__g.cbTick = 0;var __nextTick=(typeof process!='undefined'&&typeof process.nextTick=='function')?process.nextTick:function(fn){setTimeout(function(){fn()},0);};var __srcName='streamline/lib/util/flows_.js'; function __func(_, __this, __arguments, fn, index, frame, body){ if (!_) { return __future.call(__this, fn, __arguments, index); } frame.file = __srcName; frame.prev = __g.frame; if ((__g.cbTick = ++__g.cbTick % 100) === 0) return __nextTick(__cb(_, frame, -1, 0, body)); __g.frame = frame; try { body(); } catch (e) { __g.setEF(e, frame.prev); __propagate(_, e); } finally { __g.frame = frame.prev; } } function __cb(_, frame, offset, col, fn){ frame.offset = offset; frame.col = col; var ctx = __g.context; return function ___(err, result){ var oldFrame = __g.frame; __g.frame = frame; __g.context = ctx; try { if (err) { __g.setEF(err, frame); return _(err); } return fn(null, result); } catch (ex) { __g.setEF(ex, frame); return __propagate(_, ex); } finally { __g.frame = oldFrame; } } } function __future(fn, args, i){ var done, err, result; var cb = function(e, r){ done = true; err = e, result = r; }; args = Array.prototype.slice.call(args); args[i] = function ___(e, r){ cb(e, r); }; fn.apply(this, args); return function ___(_){ if (done) _.call(this, err, result); else cb = _.bind(this); } .bind(this); } function __nt(_, frame, fn){ var cb = __cb(_, frame, 0, 0, fn); return function ___(){ if ((__g.cbTick = ++__g.cbTick % 100) === 0) __nextTick(cb); else cb(); }; } function __propagate(_, err){ try { _(err); } catch (ex) { __trap(ex); } } function __trap(err){ if (err) { if (__g.context && __g.context.errorHandler) __g.context.errorHandler(err); else console.error("UNCAUGHT EXCEPTION: " + err.message + "\n" + err.stack); } } function __forIn(object){ var array = []; for (var obj in object) { array.push(obj); } return array; } (function(exports) {
/*** Generated by streamline 0.1.40 - DO NOT EDIT ***/ var __g=typeof global!=='undefined'?global:window;__g=(__g.__streamline||(__g.__streamline={}));__g.setEF=__g.setEF||function(e,f){e.__frame = e.__frame||f};var __srcName='../streamline/lib/util/flows_.js'; function __func(_, __this, __arguments, fn, index, frame, body){ if (!_) { return __future.call(__this, fn, __arguments, index); } frame.file = __srcName; frame.prev = __g.frame; __g.frame = frame; try { body(); } catch (e) { __g.setEF(e, frame.prev); __propagate(_, e); } finally { __g.frame = frame.prev; } } function __cb(_, frame, offset, col, fn){ frame.offset = offset; frame.col = col; var ctx = __g.context; return function ___(err, result){ var oldFrame = __g.frame; __g.frame = frame; __g.context = ctx; try { if (err) { __g.setEF(err, frame); return _(err); } return fn(null, result); } catch (ex) { __g.setEF(ex, frame); return __propagate(_, ex); } finally { __g.frame = oldFrame; } } } function __future(fn, args, i){ var done, err, result; var cb = function(e, r){ done = true; err = e, result = r; }; args = Array.prototype.slice.call(args); args[i] = function ___(e, r){ cb(e, r); }; fn.apply(this, args); return function ___(_){ if (done) _.call(this, err, result); else cb = _.bind(this); } .bind(this); } function __propagate(_, err){ try { _(err); } catch (ex) { __trap(ex); } } function __trap(err){ if (err) { if (__g.context && __g.context.errorHandler) __g.context.errorHandler(err); else console.error("UNCAUGHT EXCEPTION: " + err.message + "\n" + err.stack); } } function __forIn(object){ var array = []; for (var obj in object) { array.push(obj); } return array; } (function(exports) {

@@ -48,4 +48,4 @@

len = array.length;
i = 0; var __2 = false; return (function ___(__break) { var __loop = __nt(_, __frame, function __$exports_each__1() { if (__2) { i++; } else { __2 = true; } ; var __1 = (i < len); if (__1) {
return fn.call(thisObj, __cb(_, __frame, 5, 3, __loop), array[i], i); } else { __break(); } ; }); __loop(); })(function __$exports_each__1() {
i = 0; var __2 = false; return (function ___(__break) { var __more; var __loop = __cb(_, __frame, 0, 0, function __$exports_each__1() { __more = false; if (__2) { i++; } else { __2 = true; } ; var __1 = (i < len); if (__1) {
return fn.call(thisObj, __cb(_, __frame, 5, 3, function __$exports_each__1() { while (__more) { __loop(); }; __more = true; }), array[i], i); } else { __break(); } ; }); do { __loop(); } while (__more); __more = true; })(function __$exports_each__1() {
return _(null, array); }); }); };

@@ -61,4 +61,4 @@

len = array.length;
i = 0; var __3 = false; return (function ___(__break) { var __loop = __nt(_, __frame, function __$exports_map__2() { if (__3) { i++; } else { __3 = true; } ; var __2 = (i < len); if (__2) {
return fn.call(thisObj, __cb(_, __frame, 6, 15, function ___(__0, __1) { result[i] = __1; __loop(); }), array[i], i); } else { __break(); } ; }); __loop(); })(function __$exports_map__2() {
i = 0; var __3 = false; return (function ___(__break) { var __more; var __loop = __cb(_, __frame, 0, 0, function __$exports_map__2() { __more = false; if (__3) { i++; } else { __3 = true; } ; var __2 = (i < len); if (__2) {
return fn.call(thisObj, __cb(_, __frame, 6, 15, function ___(__0, __1) { result[i] = __1; while (__more) { __loop(); }; __more = true; }), array[i], i); } else { __break(); } ; }); do { __loop(); } while (__more); __more = true; })(function __$exports_map__2() {
return _(null, result); }); }); };

@@ -74,6 +74,6 @@

len = array.length;
i = 0; var __3 = false; return (function ___(__break) { var __loop = __nt(_, __frame, function __$exports_filter__3() { if (__3) { i++; } else { __3 = true; } ; var __2 = (i < len); if (__2) {
i = 0; var __3 = false; return (function ___(__break) { var __more; var __loop = __cb(_, __frame, 0, 0, function __$exports_filter__3() { __more = false; if (__3) { i++; } else { __3 = true; } ; var __2 = (i < len); if (__2) {
elt = array[i];
return fn.call(thisObj, __cb(_, __frame, 7, 7, function ___(__0, __1) { return (function __$exports_filter__3(__then) { if (__1) {
result.push(elt); __then(); } else { __then(); } ; })(__loop); }), elt); } else { __break(); } ; }); __loop(); })(function __$exports_filter__3() {
result.push(elt); __then(); } else { __then(); } ; })(function __$exports_filter__3() { while (__more) { __loop(); }; __more = true; }); }), elt); } else { __break(); } ; }); do { __loop(); } while (__more); __more = true; })(function __$exports_filter__3() {

@@ -89,5 +89,5 @@ return _(null, result); }); }); };

len = array.length;
i = 0; var __4 = false; return (function ___(__break) { var __loop = __nt(_, __frame, function __$exports_every__4() { if (__4) { i++; } else { __4 = true; } ; var __3 = (i < len); if (__3) {
i = 0; var __4 = false; return (function ___(__break) { var __more; var __loop = __cb(_, __frame, 0, 0, function __$exports_every__4() { __more = false; if (__4) { i++; } else { __4 = true; } ; var __3 = (i < len); if (__3) {
return fn.call(thisObj, __cb(_, __frame, 5, 8, function ___(__0, __2) { var __1 = !__2; return (function __$exports_every__4(__then) { if (__1) {
return _(null, false); } else { __then(); } ; })(__loop); }), array[i]); } else { __break(); } ; }); __loop(); })(function __$exports_every__4() {
return _(null, false); } else { __then(); } ; })(function __$exports_every__4() { while (__more) { __loop(); }; __more = true; }); }), array[i]); } else { __break(); } ; }); do { __loop(); } while (__more); __more = true; })(function __$exports_every__4() {

@@ -103,5 +103,5 @@ return _(null, true); }); }); };

len = array.length;
i = 0; var __3 = false; return (function ___(__break) { var __loop = __nt(_, __frame, function __$exports_some__5() { if (__3) { i++; } else { __3 = true; } ; var __2 = (i < len); if (__2) {
i = 0; var __3 = false; return (function ___(__break) { var __more; var __loop = __cb(_, __frame, 0, 0, function __$exports_some__5() { __more = false; if (__3) { i++; } else { __3 = true; } ; var __2 = (i < len); if (__2) {
return fn.call(thisObj, __cb(_, __frame, 5, 7, function ___(__0, __1) { return (function __$exports_some__5(__then) { if (__1) {
return _(null, true); } else { __then(); } ; })(__loop); }), array[i]); } else { __break(); } ; }); __loop(); })(function __$exports_some__5() {
return _(null, true); } else { __then(); } ; })(function __$exports_some__5() { while (__more) { __loop(); }; __more = true; }); }), array[i]); } else { __break(); } ; }); do { __loop(); } while (__more); __more = true; })(function __$exports_some__5() {

@@ -117,4 +117,4 @@ return _(null, false); }); }); };

len = array.length;
i = 0; var __3 = false; return (function ___(__break) { var __loop = __nt(_, __frame, function __$exports_reduce__6() { if (__3) { i++; } else { __3 = true; } ; var __2 = (i < len); if (__2) {
return fn.call(thisObj, __cb(_, __frame, 5, 7, function ___(__0, __1) { v = __1; __loop(); }), v, array[i], i, array); } else { __break(); } ; }); __loop(); })(function __$exports_reduce__6() {
i = 0; var __3 = false; return (function ___(__break) { var __more; var __loop = __cb(_, __frame, 0, 0, function __$exports_reduce__6() { __more = false; if (__3) { i++; } else { __3 = true; } ; var __2 = (i < len); if (__2) {
return fn.call(thisObj, __cb(_, __frame, 5, 7, function ___(__0, __1) { v = __1; while (__more) { __loop(); }; __more = true; }), v, array[i], i, array); } else { __break(); } ; }); do { __loop(); } while (__more); __more = true; })(function __$exports_reduce__6() {

@@ -130,4 +130,4 @@ return _(null, v); }); }); };

len = array.length;
i = (len - 1); var __3 = false; return (function ___(__break) { var __loop = __nt(_, __frame, function __$exports_reduceRight__7() { if (__3) { i--; } else { __3 = true; } ; var __2 = (i >= 0); if (__2) {
return fn.call(thisObj, __cb(_, __frame, 5, 7, function ___(__0, __1) { v = __1; __loop(); }), v, array[i], i, array); } else { __break(); } ; }); __loop(); })(function __$exports_reduceRight__7() {
i = (len - 1); var __3 = false; return (function ___(__break) { var __more; var __loop = __cb(_, __frame, 0, 0, function __$exports_reduceRight__7() { __more = false; if (__3) { i--; } else { __3 = true; } ; var __2 = (i >= 0); if (__2) {
return fn.call(thisObj, __cb(_, __frame, 5, 7, function ___(__0, __1) { v = __1; while (__more) { __loop(); }; __more = true; }), v, array[i], i, array); } else { __break(); } ; }); do { __loop(); } while (__more); __more = true; })(function __$exports_reduceRight__7() {

@@ -146,5 +146,5 @@ return _(null, v); }); }); };

return _(null, obj); } ;
var __1 = __forIn(obj); var __2 = 0; return (function ___(__break) { var __loop = __nt(_, __frame, function __$exports_eachKey__8() { var __3 = (__2 < __1.length); if (__3) { key = __1[__2++]; return (function __$exports_eachKey__8(__then) {
var __1 = __forIn(obj); var __2 = 0; return (function ___(__break) { var __more; var __loop = __cb(_, __frame, 0, 0, function __$exports_eachKey__8() { __more = false; var __3 = (__2 < __1.length); if (__3) { key = __1[__2++]; return (function __$exports_eachKey__8(__then) {
if (Object.prototype.hasOwnProperty.call(obj, key)) {
return fn.call(thisObj, __cb(_, __frame, 5, 4, __then), key, obj[key]); } else { __then(); } ; })(__loop); } else { __break(); } ; }); __loop(); })(function __$exports_eachKey__8() {
return fn.call(thisObj, __cb(_, __frame, 5, 4, __then), key, obj[key]); } else { __then(); } ; })(function __$exports_eachKey__8() { while (__more) { __loop(); }; __more = true; }); } else { __break(); } ; }); do { __loop(); } while (__more); __more = true; })(function __$exports_eachKey__8() {

@@ -151,0 +151,0 @@ return _(null, obj); }); }); };

2

package.json
{
"name": "streamline",
"description": "Asynchronous Javascript for dummies",
"version": "0.1.39",
"version": "0.1.40",
"engines": { "node": ">=0.4.0" },

@@ -6,0 +6,0 @@ "dependencies": {},

2

test/common/flows-test.js

@@ -1,2 +0,2 @@

/*** Generated by streamline 0.1.39 - DO NOT EDIT ***/ var __g=typeof global!=='undefined'?global:window;__g=(__g.__streamline||(__g.__streamline={}));__g.setEF=__g.setEF||function(e,f){e.__frame = e.__frame||f};__g.cbTick = 0;var __nextTick=(typeof process!='undefined'&&typeof process.nextTick=='function')?process.nextTick:function(fn){setTimeout(function(){fn()},0);};var __srcName='./test/common/flows-test_.js'; function __func(_, __this, __arguments, fn, index, frame, body){ if (!_) { return __future.call(__this, fn, __arguments, index); } frame.file = __srcName; frame.prev = __g.frame; if ((__g.cbTick = ++__g.cbTick % 100) === 0) return __nextTick(__cb(_, frame, -1, 0, body)); __g.frame = frame; try { body(); } catch (e) { __g.setEF(e, frame.prev); __propagate(_, e); } finally { __g.frame = frame.prev; } } function __cb(_, frame, offset, col, fn){ frame.offset = offset; frame.col = col; var ctx = __g.context; return function ___(err, result){ var oldFrame = __g.frame; __g.frame = frame; __g.context = ctx; try { if (err) { __g.setEF(err, frame); return _(err); } return fn(null, result); } catch (ex) { __g.setEF(ex, frame); return __propagate(_, ex); } finally { __g.frame = oldFrame; } } } function __future(fn, args, i){ var done, err, result; var cb = function(e, r){ done = true; err = e, result = r; }; args = Array.prototype.slice.call(args); args[i] = function ___(e, r){ cb(e, r); }; fn.apply(this, args); return function ___(_){ if (done) _.call(this, err, result); else cb = _.bind(this); } .bind(this); } function __propagate(_, err){ try { _(err); } catch (ex) { __trap(ex); } } function __trap(err){ if (err) { if (__g.context && __g.context.errorHandler) __g.context.errorHandler(err); else console.error("UNCAUGHT EXCEPTION: " + err.message + "\n" + err.stack); } } var module = QUnit.module;
/*** Generated by streamline 0.1.40 - DO NOT EDIT ***/ var __g=typeof global!=='undefined'?global:window;__g=(__g.__streamline||(__g.__streamline={}));__g.setEF=__g.setEF||function(e,f){e.__frame = e.__frame||f};var __srcName='../streamline/test/common/flows-test_.js'; function __func(_, __this, __arguments, fn, index, frame, body){ if (!_) { return __future.call(__this, fn, __arguments, index); } frame.file = __srcName; frame.prev = __g.frame; __g.frame = frame; try { body(); } catch (e) { __g.setEF(e, frame.prev); __propagate(_, e); } finally { __g.frame = frame.prev; } } function __cb(_, frame, offset, col, fn){ frame.offset = offset; frame.col = col; var ctx = __g.context; return function ___(err, result){ var oldFrame = __g.frame; __g.frame = frame; __g.context = ctx; try { if (err) { __g.setEF(err, frame); return _(err); } return fn(null, result); } catch (ex) { __g.setEF(ex, frame); return __propagate(_, ex); } finally { __g.frame = oldFrame; } } } function __future(fn, args, i){ var done, err, result; var cb = function(e, r){ done = true; err = e, result = r; }; args = Array.prototype.slice.call(args); args[i] = function ___(e, r){ cb(e, r); }; fn.apply(this, args); return function ___(_){ if (done) _.call(this, err, result); else cb = _.bind(this); } .bind(this); } function __propagate(_, err){ try { _(err); } catch (ex) { __trap(ex); } } function __trap(err){ if (err) { if (__g.context && __g.context.errorHandler) __g.context.errorHandler(err); else console.error("UNCAUGHT EXCEPTION: " + err.message + "\n" + err.stack); } } var module = QUnit.module;

@@ -3,0 +3,0 @@ var flows = require("streamline/lib/util/flows");

10

test/common/stack-test.js

@@ -1,2 +0,2 @@

/*** Generated by streamline 0.1.39 - DO NOT EDIT ***/ var __g=typeof global!=='undefined'?global:window;__g=(__g.__streamline||(__g.__streamline={}));__g.setEF=__g.setEF||function(e,f){e.__frame = e.__frame||f};__g.cbTick = 0;var __nextTick=(typeof process!='undefined'&&typeof process.nextTick=='function')?process.nextTick:function(fn){setTimeout(function(){fn()},0);};var __srcName='./test/common/stack-test_.js'; function __func(_, __this, __arguments, fn, index, frame, body){ if (!_) { return __future.call(__this, fn, __arguments, index); } frame.file = __srcName; frame.prev = __g.frame; if ((__g.cbTick = ++__g.cbTick % 100) === 0) return __nextTick(__cb(_, frame, -1, 0, body)); __g.frame = frame; try { body(); } catch (e) { __g.setEF(e, frame.prev); __propagate(_, e); } finally { __g.frame = frame.prev; } } function __cb(_, frame, offset, col, fn){ frame.offset = offset; frame.col = col; var ctx = __g.context; return function ___(err, result){ var oldFrame = __g.frame; __g.frame = frame; __g.context = ctx; try { if (err) { __g.setEF(err, frame); return _(err); } return fn(null, result); } catch (ex) { __g.setEF(ex, frame); return __propagate(_, ex); } finally { __g.frame = oldFrame; } } } function __future(fn, args, i){ var done, err, result; var cb = function(e, r){ done = true; err = e, result = r; }; args = Array.prototype.slice.call(args); args[i] = function ___(e, r){ cb(e, r); }; fn.apply(this, args); return function ___(_){ if (done) _.call(this, err, result); else cb = _.bind(this); } .bind(this); } function __nt(_, frame, fn){ var cb = __cb(_, frame, 0, 0, fn); return function ___(){ if ((__g.cbTick = ++__g.cbTick % 100) === 0) __nextTick(cb); else cb(); }; } function __propagate(_, err){ try { _(err); } catch (ex) { __trap(ex); } } function __trap(err){ if (err) { if (__g.context && __g.context.errorHandler) __g.context.errorHandler(err); else console.error("UNCAUGHT EXCEPTION: " + err.message + "\n" + err.stack); } } function __tryCatch(_, fn){ try { fn(); } catch (e) { try { _(e); } catch (ex) { __trap(ex); } } } var module = QUnit.module;
/*** Generated by streamline 0.1.40 - DO NOT EDIT ***/ var __g=typeof global!=='undefined'?global:window;__g=(__g.__streamline||(__g.__streamline={}));__g.setEF=__g.setEF||function(e,f){e.__frame = e.__frame||f};var __srcName='../streamline/test/common/stack-test_.js'; function __func(_, __this, __arguments, fn, index, frame, body){ if (!_) { return __future.call(__this, fn, __arguments, index); } frame.file = __srcName; frame.prev = __g.frame; __g.frame = frame; try { body(); } catch (e) { __g.setEF(e, frame.prev); __propagate(_, e); } finally { __g.frame = frame.prev; } } function __cb(_, frame, offset, col, fn){ frame.offset = offset; frame.col = col; var ctx = __g.context; return function ___(err, result){ var oldFrame = __g.frame; __g.frame = frame; __g.context = ctx; try { if (err) { __g.setEF(err, frame); return _(err); } return fn(null, result); } catch (ex) { __g.setEF(ex, frame); return __propagate(_, ex); } finally { __g.frame = oldFrame; } } } function __future(fn, args, i){ var done, err, result; var cb = function(e, r){ done = true; err = e, result = r; }; args = Array.prototype.slice.call(args); args[i] = function ___(e, r){ cb(e, r); }; fn.apply(this, args); return function ___(_){ if (done) _.call(this, err, result); else cb = _.bind(this); } .bind(this); } function __propagate(_, err){ try { _(err); } catch (ex) { __trap(ex); } } function __trap(err){ if (err) { if (__g.context && __g.context.errorHandler) __g.context.errorHandler(err); else console.error("UNCAUGHT EXCEPTION: " + err.message + "\n" + err.stack); } } function __tryCatch(_, fn){ try { fn(); } catch (e) { try { _(e); } catch (ex) { __trap(ex); } } } var module = QUnit.module;

@@ -34,6 +34,6 @@

return fail(__cb(_, __frame, 7, 2, __then), code); } else { __then(); } ; })(function __$A() {
i = 0; var __6 = false; return (function ___(__break) { var __loop = __nt(_, __frame, function __$A() { if (__6) { i++; } else { __6 = true; } ; var __5 = (i < 6); if (__5) { return (function __$A(__then) {
i = 0; var __6 = false; return (function ___(__break) { var __more; var __loop = __cb(_, __frame, 0, 0, function __$A() { __more = false; if (__6) { i++; } else { __6 = true; } ; var __5 = (i < 6); if (__5) { return (function __$A(__then) {
if ((code == i)) {
return fail(__cb(_, __frame, 10, 3, __then), code); } else { __then(); } ; })(function __$A() {
return nextTick(__cb(_, __frame, 11, 2, __loop)); }); } else { __break(); } ; }); __loop(); })(function __$A() { return (function __$A(__then) {
return nextTick(__cb(_, __frame, 11, 2, function __$A() { while (__more) { __loop(); }; __more = true; })); }); } else { __break(); } ; }); do { __loop(); } while (__more); __more = true; })(function __$A() { return (function __$A(__then) {

@@ -101,4 +101,4 @@ if ((code == 6)) {

s = "";
i = 0; var __3 = false; return (function ___(__break) { var __loop = __nt(_, __frame, function __$I() { if (__3) { i++; } else { __3 = true; } ; var __2 = (i < code); if (__2) {
return H(__cb(_, __frame, 3, 7, function ___(__0, __1) { s += __1; __loop(); }), i); } else { __break(); } ; }); __loop(); })(function __$I() {
i = 0; var __3 = false; return (function ___(__break) { var __more; var __loop = __cb(_, __frame, 0, 0, function __$I() { __more = false; if (__3) { i++; } else { __3 = true; } ; var __2 = (i < code); if (__2) {
return H(__cb(_, __frame, 3, 7, function ___(__0, __1) { s += __1; while (__more) { __loop(); }; __more = true; }), i); } else { __break(); } ; }); do { __loop(); } while (__more); __more = true; })(function __$I() {
return _(null, s); }); });};

@@ -105,0 +105,0 @@

90

test/common/transform-test.js

@@ -278,3 +278,5 @@ var module = QUnit.module;

return (function ___(__break){
var __loop = __nt(_, __frame, function __$f(){
var __more;
var __loop = __cb(_, __frame, 0, 0, function __$f(){
__more = false;
var __1 = cond;

@@ -284,3 +286,6 @@ if (__1) {

f3();
__loop();
while (__more) {
__loop();
}
__more = true;
}));

@@ -292,3 +297,7 @@ }

});
__loop();
do {
__loop();
}
while (__more);
__more = true;
})(function __$f(){

@@ -319,3 +328,5 @@ f4();

return (function ___(__break){
var __loop = __nt(_, __frame, function __$f(){
var __more;
var __loop = __cb(_, __frame, 0, 0, function __$f(){
__more = false;
var __2 = (__1 || cond);

@@ -326,3 +337,6 @@ if (__2) {

f3();
__loop();
while (__more) {
__loop();
}
__more = true;
}));

@@ -334,3 +348,7 @@ }

});
__loop();
do {
__loop();
}
while (__more);
__more = true;
})(function __$f(){

@@ -362,3 +380,5 @@ f4();

return (function ___(__break){
var __loop = __nt(_, __frame, function __$f(){
var __more;
var __loop = __cb(_, __frame, 0, 0, function __$f(){
__more = false;
if (__2) {

@@ -374,3 +394,6 @@ i++;

f3();
__loop();
while (__more) {
__loop();
}
__more = true;
}));

@@ -382,3 +405,7 @@ }

});
__loop();
do {
__loop();
}
while (__more);
__more = true;
})(function __$f(){

@@ -410,3 +437,5 @@ f4();

return (function ___(__break){
var __loop = __nt(_, __frame, function __$f(){
var __more;
var __loop = __cb(_, __frame, 0, 0, function __$f(){
__more = false;
var __3 = (__2 < __1.length);

@@ -417,3 +446,6 @@ if (__3) {

f3(k);
__loop();
while (__more) {
__loop();
}
__more = true;
}), k);

@@ -425,3 +457,7 @@ }

});
__loop();
do {
__loop();
}
while (__more);
__more = true;
})(function __$f(){

@@ -454,3 +490,5 @@ f4();

return (function ___(__break){
var __loop = __nt(_, __frame, function __$f(){
var __more;
var __loop = __cb(_, __frame, 0, 0, function __$f(){
__more = false;
var __3 = (__2 < __1.length);

@@ -461,3 +499,6 @@ if (__3) {

f3(k);
__loop();
while (__more) {
__loop();
}
__more = true;
}), k);

@@ -469,3 +510,7 @@ }

});
__loop();
do {
__loop();
}
while (__more);
__more = true;
})(function __$f(){

@@ -598,7 +643,12 @@ f4();

return (function ___(__break){
var __loop = __nt(_, __frame, function __$f(){
var __more;
var __loop = __cb(_, __frame, 0, 0, function __$f(){
__more = false;
return f2(__cb(_, __frame, 2, 11, function ___(__0, __1){
if (__1) {
f3();
__loop();
while (__more) {
__loop();
}
__more = true;
}

@@ -610,3 +660,7 @@ else {

});
__loop();
do {
__loop();
}
while (__more);
__more = true;
})(function __$f(){

@@ -613,0 +667,0 @@ f4();

8

test/server/streams-test.js

@@ -1,2 +0,2 @@

/*** Generated by streamline 0.1.39 - DO NOT EDIT ***/ "use strict"; var __g=typeof global!=='undefined'?global:window;__g=(__g.__streamline||(__g.__streamline={}));__g.setEF=__g.setEF||function(e,f){e.__frame = e.__frame||f};__g.cbTick = 0;var __nextTick=(typeof process!='undefined'&&typeof process.nextTick=='function')?process.nextTick:function(fn){setTimeout(function(){fn()},0);};var __srcName='./test/server/streams-test_.js'; function __func(_, __this, __arguments, fn, index, frame, body){ if (!_) { return __future.call(__this, fn, __arguments, index); } frame.file = __srcName; frame.prev = __g.frame; if ((__g.cbTick = ++__g.cbTick % 100) === 0) return __nextTick(__cb(_, frame, -1, 0, body)); __g.frame = frame; try { body(); } catch (e) { __g.setEF(e, frame.prev); __propagate(_, e); } finally { __g.frame = frame.prev; } } function __cb(_, frame, offset, col, fn){ frame.offset = offset; frame.col = col; var ctx = __g.context; return function ___(err, result){ var oldFrame = __g.frame; __g.frame = frame; __g.context = ctx; try { if (err) { __g.setEF(err, frame); return _(err); } return fn(null, result); } catch (ex) { __g.setEF(ex, frame); return __propagate(_, ex); } finally { __g.frame = oldFrame; } } } function __future(fn, args, i){ var done, err, result; var cb = function(e, r){ done = true; err = e, result = r; }; args = Array.prototype.slice.call(args); args[i] = function ___(e, r){ cb(e, r); }; fn.apply(this, args); return function ___(_){ if (done) _.call(this, err, result); else cb = _.bind(this); } .bind(this); } function __nt(_, frame, fn){ var cb = __cb(_, frame, 0, 0, fn); return function ___(){ if ((__g.cbTick = ++__g.cbTick % 100) === 0) __nextTick(cb); else cb(); }; } function __propagate(_, err){ try { _(err); } catch (ex) { __trap(ex); } } function __trap(err){ if (err) { if (__g.context && __g.context.errorHandler) __g.context.errorHandler(err); else console.error("UNCAUGHT EXCEPTION: " + err.message + "\n" + err.stack); } } var streams = require("streamline/lib/streams/streams");
/*** Generated by streamline 0.1.40 - DO NOT EDIT ***/ "use strict"; var __g=typeof global!=='undefined'?global:window;__g=(__g.__streamline||(__g.__streamline={}));__g.setEF=__g.setEF||function(e,f){e.__frame = e.__frame||f};var __srcName='../streamline/test/server/streams-test_.js'; function __func(_, __this, __arguments, fn, index, frame, body){ if (!_) { return __future.call(__this, fn, __arguments, index); } frame.file = __srcName; frame.prev = __g.frame; __g.frame = frame; try { body(); } catch (e) { __g.setEF(e, frame.prev); __propagate(_, e); } finally { __g.frame = frame.prev; } } function __cb(_, frame, offset, col, fn){ frame.offset = offset; frame.col = col; var ctx = __g.context; return function ___(err, result){ var oldFrame = __g.frame; __g.frame = frame; __g.context = ctx; try { if (err) { __g.setEF(err, frame); return _(err); } return fn(null, result); } catch (ex) { __g.setEF(ex, frame); return __propagate(_, ex); } finally { __g.frame = oldFrame; } } } function __future(fn, args, i){ var done, err, result; var cb = function(e, r){ done = true; err = e, result = r; }; args = Array.prototype.slice.call(args); args[i] = function ___(e, r){ cb(e, r); }; fn.apply(this, args); return function ___(_){ if (done) _.call(this, err, result); else cb = _.bind(this); } .bind(this); } function __propagate(_, err){ try { _(err); } catch (ex) { __trap(ex); } } function __trap(err){ if (err) { if (__g.context && __g.context.errorHandler) __g.context.errorHandler(err); else console.error("UNCAUGHT EXCEPTION: " + err.message + "\n" + err.stack); } } var streams = require("streamline/lib/streams/streams");

@@ -40,5 +40,5 @@

i = 0; var __2 = false; return (function ___(__break) { var __loop = __nt(_, __frame, function __$__1() { if (__2) { i++; } else { __2 = true; } ; var __1 = (i < bufCount); if (__1) {
i = 0; var __2 = false; return (function ___(__break) { var __more; var __loop = __cb(_, __frame, 0, 0, function __$__1() { __more = false; if (__2) { i++; } else { __2 = true; } ; var __1 = (i < bufCount); if (__1) {
return res.write(__cb(_, __frame, 6, 2, function __$__1() {
return process.nextTick(__cb(_, __frame, 7, 2, __loop)); }), makeBuffer(i)); } else { __break(); } ; }); __loop(); })(function __$__1() {
return process.nextTick(__cb(_, __frame, 7, 2, function __$__1() { while (__more) { __loop(); }; __more = true; })); }), makeBuffer(i)); } else { __break(); } ; }); do { __loop(); } while (__more); __more = true; })(function __$__1() {

@@ -111,3 +111,3 @@ res.end(); _(); }); });

start(); _(); }), name, options, function __1(_, resp) { var i, total, len, buf; var __frame = { name: "__1", line: 102 }; return __func(_, this, arguments, __1, 0, __frame, function __$__1() { i = 0; total = 0; var __3 = false; return (function ___(__break) { var __loop = __nt(_, __frame, function __$__1() { if (__3) { i++; } else { __3 = true; } ; var __2 = (total < totalSize); if (__2) { len = ((size && (typeof size === "function")) ? size() : size); return resp.read(__cb(_, __frame, 3, 15, function ___(__0, __1) { buf = __1; total = checkBuffer(buf, total); __loop(); }), len); } else { __break(); } ; }); __loop(); })(_); }); }); }); }); };
start(); _(); }), name, options, function __1(_, resp) { var i, total, len, buf; var __frame = { name: "__1", line: 102 }; return __func(_, this, arguments, __1, 0, __frame, function __$__1() { i = 0; total = 0; var __3 = false; return (function ___(__break) { var __more; var __loop = __cb(_, __frame, 0, 0, function __$__1() { __more = false; if (__3) { i++; } else { __3 = true; } ; var __2 = (total < totalSize); if (__2) { len = ((size && (typeof size === "function")) ? size() : size); return resp.read(__cb(_, __frame, 3, 15, function ___(__0, __1) { buf = __1; total = checkBuffer(buf, total); while (__more) { __loop(); }; __more = true; }), len); } else { __break(); } ; }); do { __loop(); } while (__more); __more = true; })(_); }); }); }); }); };

@@ -114,0 +114,0 @@

SocketSocket SOC 2 Logo

Product

  • Package Alerts
  • Integrations
  • Docs
  • Pricing
  • FAQ
  • Roadmap
  • Changelog

About

Packages

npm

Go

Maven

PyPI

Rubygems

Stay in touch

Get open source security insights delivered straight into your inbox.

  • Terms
  • Privacy
  • Security

Made with ⚡️ by Socket Inc