bumped version to 0.12.1 and recompiled

Author: bjouhier

lib/callbacks/builtins.js

@@ -1,4 +1,4 @@
-/*** Generated by streamline 0.12.0 (callbacks) - DO NOT EDIT ***/ var __rt=require('../callbacks/runtime').runtime(__filename, false),__func=__rt.__func,__cb=__rt.__cb; 
+/*** Generated by streamline 0.12.1 (callbacks) - DO NOT EDIT ***/ var __rt=require('../callbacks/runtime').runtime(__filename, false),__func=__rt.__func,__cb=__rt.__cb; 
 
 
 

lib/callbacks/compile.js

@@ -1,4 +1,4 @@
-/*** Generated by streamline 0.12.0 (callbacks) - DO NOT EDIT ***/ "use strict"; var __rt=require('../callbacks/runtime').runtime(__filename, false),__func=__rt.__func,__cb=__rt.__cb,__catch=__rt.__catch,__tryCatch=__rt.__tryCatch; 
+/*** Generated by streamline 0.12.1 (callbacks) - DO NOT EDIT ***/ "use strict"; var __rt=require('../callbacks/runtime').runtime(__filename, false),__func=__rt.__func,__cb=__rt.__cb,__catch=__rt.__catch,__tryCatch=__rt.__tryCatch; 
 
 
 
@@ -81,7 +81,7 @@ function mkdirp(_, path) { var __frame = { name: 'mkdirp', line: 79 }; return __
                     return fs.mkdir(path, _0755, __cb(_, __frame, 2, 0, __then, true, false)); }); }(function ___(err, __result) { 
                 __catch(function __$mkdirp() { if (err) { 
                         return function __$mkdirp(__then) { if (err.code == 'EEXIST') { 
-                                return fs.stat(path, __cb(_, __frame, 5, 0, function ___(__0, __2) { var __1 = __2.isDirectory(); return function __$mkdirp(__then) { if (__1) { 
+                                return fs.stat(path, __cb(_, __frame, 5, 0, function ___(__0, __3) { var __2 = __3; var __1 = __2.isDirectory(); return function __$mkdirp(__then) { if (__1) { 
                                             return _(null); } else { __then(); } }(function __$mkdirp() { 
 
                                         return _(err); }); }, true, false)); } else { __then(); } }(function __$mkdirp() { 

lib/callbacks/flows.js

@@ -1,4 +1,4 @@
-/*** Generated by streamline 0.12.0 (callbacks) - DO NOT EDIT ***/ var __rt=require('../callbacks/runtime').runtime(__filename, false),__func=__rt.__func,__cb=__rt.__cb; 
+/*** Generated by streamline 0.12.1 (callbacks) - DO NOT EDIT ***/ var __rt=require('../callbacks/runtime').runtime(__filename, false),__func=__rt.__func,__cb=__rt.__cb; 
 
 
 
@@ -202,7 +202,7 @@
     exports.queue = function (options) { 
         options = options || {}; 
         var max = options.max != null ? options.max : -1; 
-        var callback = null, q = [], pendingWrites = []; 
+        var callback = null, err = null, q = [], pendingWrites = []; 
         return { read: __rt.streamlinify(function (cb) { 
 
                 if (callback) throw new Error('already getting'); 
@@ -211,12 +211,12 @@
 
                     if (q.length === 0) q = []; 
                     exports.setImmediate(function () { 
-                        cb(null, item); }); 
+                        cb(err, item); }); 
 
                     if (pendingWrites.length > 0) { 
                         var wr = pendingWrites.shift(); 
                         exports.setImmediate(function () { 
-                            wr[0](null, wr[1]); }); } } else { 
+                            wr[0](err, wr[1]); }); } } else { 
 
 
 
@@ -226,7 +226,7 @@
 
                 if (this.put(item)) { 
                     exports.setImmediate(function () { 
-                        cb(); }); } else { 
+                        cb(err); }); } else { 
 
 
                     pendingWrites.push([ cb, item ]); } }, 0), put: function (item, force) { 
@@ -240,12 +240,13 @@
                     var cb = callback; 
                     callback = null; 
                     exports.setImmediate(function () { 
-                        cb(null, item); }); } 
+                        cb(err, item); }); } 
 
 
-                return true; }, end: function () { 
+                return true; }, end: function (e) { 
 
 
+                err = err || e; 
                 this.put(undefined, true); } }; }; 
 
 
@@ -255,8 +256,8 @@
 
 
 
-    exports.collect = function exports_collect__10(_, futures) { var __frame = { name: 'exports_collect__10', line: 258 }; return __func(_, this, arguments, exports_collect__10, 0, __frame, function __$exports_collect__10() { 
-            return function __$exports_collect__10(_) { var __2 = futures; if (!__2) { return _(null, __2); } return futures.map_(__cb(_, __frame, 1, 0, _, true, false), function __1(_, future) { var __frame = { name: '__1', line: 259 }; return __func(_, this, arguments, __1, 0, __frame, function __$__1() { 
+    exports.collect = function exports_collect__10(_, futures) { var __frame = { name: 'exports_collect__10', line: 259 }; return __func(_, this, arguments, exports_collect__10, 0, __frame, function __$exports_collect__10() { 
+            return function __$exports_collect__10(_) { var __2 = futures; if (!__2) { return _(null, __2); } return futures.map_(__cb(_, __frame, 1, 0, _, true, false), function __1(_, future) { var __frame = { name: '__1', line: 260 }; return __func(_, this, arguments, __1, 0, __frame, function __$__1() { 
                         return future(__cb(_, __frame, 1, 0, _, true, false)); }); }); }(__cb(_, __frame, 1, 0, _, true, false)); }); }; 
 
 
@@ -301,7 +302,7 @@
 
 
 
-    exports.nextTick = function exports_nextTick__11(_) { var __frame = { name: 'exports_nextTick__11', line: 304 }; return __func(_, this, arguments, exports_nextTick__11, 0, __frame, function __$exports_nextTick__11() { 
+    exports.nextTick = function exports_nextTick__11(_) { var __frame = { name: 'exports_nextTick__11', line: 305 }; return __func(_, this, arguments, exports_nextTick__11, 0, __frame, function __$exports_nextTick__11() { 
             return nextTick(__cb(_, __frame, 1, 0, function __$exports_nextTick__11() { _(); }, true, false)); }); }; 
 
 
@@ -333,15 +334,15 @@
 
 
 
-    exports.sleep = function exports_sleep__12(_, millis) { var __frame = { name: 'exports_sleep__12', line: 336 }; return __func(_, this, arguments, exports_sleep__12, 0, __frame, function __$exports_sleep__12() { 
+    exports.sleep = function exports_sleep__12(_, millis) { var __frame = { name: 'exports_sleep__12', line: 337 }; return __func(_, this, arguments, exports_sleep__12, 0, __frame, function __$exports_sleep__12() { 
             return setTimeout(__cb(_, __frame, 1, 0, _, true, false), millis); }); }; 
 
 
     exports.eventHandler = function (fn) { 
         return function () { 
             var that = this; 
             var args = Array.prototype.slice(arguments, 0); 
-            return function __1(_) { var __frame = { name: '__1', line: 344 }; return __func(_, this, arguments, __1, 0, __frame, function __$__1() { 
+            return function __1(_) { var __frame = { name: '__1', line: 345 }; return __func(_, this, arguments, __1, 0, __frame, function __$__1() { 
                     return fn.apply_(__cb(_, __frame, 1, 0, _, true, false), that, args, 0); }); }(function (err) { 
 
                 if (err) throw err; }); }; }; 
@@ -350,7 +351,7 @@
 
 
 
-    exports.apply = function apply(_, fn, thisObj, args, index) { var __frame = { name: 'apply', line: 353 }; return __func(_, this, arguments, apply, 0, __frame, function __$apply() { 
+    exports.apply = function apply(_, fn, thisObj, args, index) { var __frame = { name: 'apply', line: 354 }; return __func(_, this, arguments, apply, 0, __frame, function __$apply() { 
             return fn.apply_(__cb(_, __frame, 1, 0, _, true, false), thisObj, args, index); }); }; 
 
 

lib/callbacks/runtime-all.js

@@ -422,7 +422,7 @@ function require(str) {
 	exports.stackTraceEnabled = true;
 })(typeof exports !== 'undefined' ? exports : (Streamline.runtime = Streamline.runtime || {}));
 require && require("../callbacks/builtins");
-/*** Generated by streamline 0.12.0 (callbacks) - DO NOT EDIT ***/ var __rt=require('../callbacks/runtime').runtime(__filename, false),__func=__rt.__func,__cb=__rt.__cb; 
+/*** Generated by streamline 0.12.1 (callbacks) - DO NOT EDIT ***/ var __rt=require('../callbacks/runtime').runtime(__filename, false),__func=__rt.__func,__cb=__rt.__cb;