arch-stream - npm Package Compare versions

Comparing version 0.0.38 to 0.0.39

dist/arch-stream.js

@@ -1,25 +0,29 @@
-/*! arch-stream v0.0.38 | (c) 2015, falsandtru | MIT Licence */
-define = typeof define === "function"
+/*! arch-stream v0.0.39 | (c) 2015, falsandtru | MIT Licence */
+define = typeof define === "function" && define.amd
   ? define
-  : function (m, rs, f) {
-    if (!f) return define(m[2], m, rs);
-    var ns = define['@arch-stream'] = define['@arch-stream'] || {};
-    f.apply(this,
-      rs.map(function (r) {
-        switch (r) {
-          case 'require': {
-            return typeof require === 'function' ? require : void 0;
+  : (function () {
+    var package = 'arch-stream',
+        workspace = {};
+    return function define(m, rs, f) {
+      return !f
+        ? void define(package, m, rs)
+        : void f.apply(this, rs.map(function (r) {
+          switch (r) {
+            case 'require': {
+              return typeof require === 'function' ? require : void 0;
+            }
+            case 'exports': {
+              return m.indexOf('/') === -1
+                ? workspace[m] = typeof exports === 'undefined' ? window[m] = window[m] || {} : exports
+                : workspace[m] = workspace.hasOwnProperty(m) ? workspace[m] : {};
+            }
+            default: {
+              return workspace[r]
+                  || typeof require === 'function' && require(r)
+                  || window[r];
+            }
           }
-          case 'exports': {
-            return m.indexOf('/') === -1
-              ? ns[m] = typeof exports === 'undefined' ? window[m] = window[m] || {} : exports
-              : ns[m] = ns.hasOwnProperty(m) ? ns[m] : {};
-          }
-          default: {
-            return ns[r];
-          }
-        }
-      })
-    );
-  };
+        }));
+    };
+  })();
 define('src/lib/thenable', [
@@ -26,0 +30,0 @@ 'require',

dist/arch-stream.min.js

@@ -1,2 +0,2 @@
-/*! arch-stream v0.0.38 | (c) 2015, falsandtru | MIT Licence */
-define="function"==typeof define?define:function(t,e,r){if(!r)return define(t[2],t,e);var i=define["@arch-stream"]=define["@arch-stream"]||{};r.apply(this,e.map(function(e){switch(e){case"require":return"function"==typeof require?require:void 0;case"exports":return-1===t.indexOf("/")?i[t]="undefined"==typeof exports?window[t]=window[t]||{}:exports:i[t]=i.hasOwnProperty(t)?i[t]:{};default:return i[e]}}))},define("src/lib/thenable",["require","exports"],function(t,e){"use strict";function r(t){return!!t&&"object"==typeof t&&void 0!==t.then}e.isThenable=r}),define("src/lib/tick",["require","exports"],function(t,e){"use strict";var r;!function(t){function e(t){void n.push(t),void i()}function r(){void i(),void--o;for(var t=n.length;t-- >0;)void n.shift()()}function i(){if(0!==n.length)if(s)for(;2>o;)void Promise.resolve().then(r),void++o;else for(;o<u.length;)void setTimeout(r,u[o%u.length]),void++o}t.queue=e;var n=[],o=0,s="function"==typeof Promise,u=[0,4,10,20,25].reverse()}(r||(r={}));var i=Function("return typeof process === 'object' && typeof window !== 'object'")();Object.defineProperty(e,"__esModule",{value:!0}),e["default"]=i?Function("return fn => process.nextTick(fn)")():r.queue}),define("src/lib/message",["require","exports","src/lib/thenable","src/lib/tick"],function(t,e,r,i){"use strict";function n(t){return t}var o=Object.create(null),s=function(){function t(t,e){void 0===e&&(e=n),this.parent=t,this.listener=e,this.memory_=o,this.collection_=[],this.transform_=!1,this.listeners_=[],t&&(this.parent.child_=this)}return t.prototype.root=function(){return this.parent?this.parent.root():this},t.prototype.collect_=function(){if(this.collection_.length>0)return this.collection_;var t=this,e=[];do void e.push(t);while(t=t.child_);return this.collection_=e},t.prototype.transport_=function(t,e){function i(t,i,u){function c(t){return r.isThenable(t)?void t.then(c,c):(o=!0,i=u?t:i,void(s&&n.child_&&void n.child_.send(i,e)))}return t.every(function(t){n=t,n.memory_=i;var e=n.listener(n.memory_);return r.isThenable(e)?(o=!1,void e.then(c,c),o):(i=u?e:i,!0)})}var n,o=!1,s=!1,u=i(this.collect_(),t,this.transform_);s=!0,u&&"function"==typeof e&&void e(t)},t.prototype.clone=function(){function e(r){return r.parent?new t(e(r.parent),r.listener):new t(void 0,r.listener)}return e(this)},t.prototype.connect=function(t){return this.parent.child_=t,t.parent=this.parent,this},t.prototype.send=function(t,e,r){switch(!0){case"function"==typeof e:return this.send(t,!1,e);case e===!0:return void i["default"](this.transport_.bind(this,t,r)),this;case e===!1:default:return void this.transport_(t,r),this}},t.prototype.recv=function(e){var r=new t(this);return this.listener=e,this.collection_=[],this.memory_!==o&&void this.send(this.memory_),r},t.prototype.trans=function(t){return this.transform_=!0,this.recv(t)},t.prototype.then=function(e,r){var i=this,n=new t;return this.listeners_.push(n),this.trans(function(t){var e=i.listeners_;i.listeners_=[];for(var r=0;r<e.length;++r)e[r].send(t)}),n.trans(e)},t}();Object.defineProperty(e,"__esModule",{value:!0}),e["default"]=s}),define("src/lib/throttle",["require","exports"],function(t,e){"use strict";var r=function(){function t(){this.queue_=[],this.processing_=[],this.limit_=1/0,this.volume_=1/0}return t.prototype.isDrainable_=function(){return this.processing_.length<this.volume_},t.prototype.discharger_=function(t,e){},t.prototype.flow=function(t,e,r){void 0===e&&(e=1/0),void 0===r&&(r=function(){return null}),this.volume_=t,this.limit_=e,this.discharger_=r},t.prototype.enqueue=function(t){if(this.isDrainable_())return void this.processing_.push(t),void this.resolver_(t),!0;this.queue_.push(t);do void this.discharger_(this.queue_,this.processing_);while(this.processing_.length+this.queue_.length>this.limit_);return!1},t.prototype.dequeue=function(t){var e=this.processing_.indexOf(t);e>0?void this.processing_.splice(e,1):void this.processing_.shift(),this.queue_.length>0&&this.isDrainable_()&&void this.enqueue(this.queue_.shift())},t.prototype.register=function(t){this.resolver_=t},t}();Object.defineProperty(e,"__esModule",{value:!0}),e["default"]=r}),define("src/lib/noop",["require","exports"],function(t,e){"use strict";function r(){}Object.defineProperty(e,"__esModule",{value:!0}),e["default"]=r}),define("src/stream/modular",["require","exports","src/lib/throttle","src/lib/tick","src/lib/noop"],function(t,e,r,i,n){"use strict";var o=function(){function t(t,e,r){var n=this;void 0===e&&(e=1),this.procs=t,this.count=e,this.branched=r,this.read=this.read.bind(this),this.write=this.write.bind(this),void i["default"](function(t){return 0<n.count&&n.count<1/0&&n.throwCountDeprivedError()})}return t.prototype.compose_=function(){this.last_=this.procs.map(function(t){return t.clone()}).reduce(function(t,e){return t.connect(e.root())&&e}),this.first_=this.last_.root()},t.prototype.wrap=function(t){function e(e){return function(r){return t(r,e)}}void this.compose_();var r=this.last_;do r=r.parent,r.listener=e(r.listener);while(r.parent);return this.procs=[this.last_],this},t.prototype.read_=function(t){void--this.count,this.count<0&&void this.throwCountExceededError(),void this.compose_(),void this.last_.recv(t)},t.prototype.read=function(t){var e=this;void 0===t&&(t=n["default"]);var r=!1;return void this.read_(function(n){e.flow_&&void i["default"](function(){return void e.flow_.dequeue(n)}),r&&void t(n)}),r=!0,this},t.prototype.write_=function(t,e){void this.first_.send(t,e)},t.prototype.write=function(t,e){return this.flow_?void this.flow_.enqueue(t):void this.write_(t,e),this},t.prototype.flow=function(t,e,i){var n=this;return void 0===e&&(e=1/0),this.flow_=new r["default"],void this.flow_.flow(t,e,i),void this.flow_.register(function(t){return n.write_(t)}),this},t.prototype.throwCountExceededError=function(){throw new Error("ArchStream: Import and read counts are exeeded.")},t.prototype.throwCountDeprivedError=function(){throw this.count=0,new Error("ArchStream: Import and read counts are not deprived.")},t}();Object.defineProperty(e,"__esModule",{value:!0}),e["default"]=o}),define("src/stream/compose",["require","exports","src/stream/modular"],function(t,e,r){"use strict";var i=function(){function t(t){this.extract_=t,this.procs_=[],this.branched_=0}return t.prototype.register=function(t){var e=this.procs_.length;return void t.reduceRight(function(t,r,i){return t[i+e]=r,t},this.procs_),this},t.prototype["import"]=function(e,r){var i=this;return void this.throwErrorIfNotImportable_(e,r),r&&(e=(new t)["import"](e)["export"]().wrap(function(t,e){return i.extract_(t)instanceof r?e(t):0})),void--e.count,e.count<0&&void e.throwCountExceededError(),void this.register(e.procs),this},t.prototype["export"]=function(t){return new r["default"](this.procs_,t,this.branched_)},t.prototype.throwErrorIfNotImportable_=function(t,e){e?((t.branched>0||this.branched_>1)&&(void--t.count,void this.throwConditionalImportError()),this.branched_=1):(t.branched>0&&this.branched_>0&&(void--t.count,void this.throwConditionalImportError()),this.branched_=t.branched>0?t.branched+1:t.branched)},t.prototype.throwConditionalImportError=function(){throw new Error("ArchStream: Conditional import cannot call from different streams.")},t}();Object.defineProperty(e,"__esModule",{value:!0}),e["default"]=i}),define("src/stream/transform",["require","exports","src/lib/message","src/stream/compose","src/stream/modular"],function(t,e,r,i,n){"use strict";var o=function(){function t(t,e){var i=this;void 0===e&&(e=new r["default"]),this.parent_=t,this.message_=e,this.proxies_=[],this.parent_&&void this.parent_.proxies_.reduce(function(t,e){return i.proxy(e)},void 0)}return t.prototype.pipe=function(e){return new t(this,this.message_.recv(e))},t.prototype["import"]=function(t,e){return t instanceof n["default"]?(new i["default"])["import"](t,e):new i["default"](t)},t.prototype["export"]=function(t){return(new i["default"]).register([this.message_])["export"](t)},t.prototype.proxy=function(e){function r(e,i,n){function o(t){return Array.isArray(t)?t:[t]}var s=e.proxies_.filter(function(t){return"function"==typeof t[i]}).reduce(function(t,e){return o(e[i].apply(void 0,t)||t)},n),u="pipe";switch(i){case u:return t.prototype[i].call(e,s[0]);case"import":throw new Error("ArchStream: `import` method cannot extend by proxy.");case"export":return(c=t.prototype[i]).call.apply(c,[r(e,u,s)].concat(n));default:return r(e,u,s)}var c}var i=this,n="function"==typeof e?e():e;return this.proxies_.push(n),void Object.keys(n).filter(function(t){return t.length>0&&"_"!==t[0]&&"_"!==t[t.length-1]}).filter(function(t){return"function"==typeof n[t]}).reduce(function(t,e){return i[e]=function(){for(var t=[],n=0;n<arguments.length;n++)t[n-0]=arguments[n];return r(i,e,t)}},void 0),this},t}();Object.defineProperty(e,"__esModule",{value:!0}),e["default"]=o}),define("src/proxy/case",["require","exports"],function(t,e){"use strict";function r(t,e){function r(){for(var t=[],r=0;r<arguments.length;r++)t[r-0]=arguments[r];return function(r){var n=+i[e(r)+""];n>-1&&n<t.length&&t[n](r)}}var i=Object.create(null);return void t.reduce(function(t,e,r){return i[e+""]=r},void 0),function(t){return{pipe:r}}}Object.defineProperty(e,"__esModule",{value:!0}),e["default"]=r}),define("src/proxy/hook",["require","exports","src/lib/noop"],function(t,e,r){"use strict";function i(t){function e(){for(var t=[],e=0;e<arguments.length;e++)t[e-0]=arguments[e];return t.map(function(t){return function(e){n(e),t(e),s(e)}})}var i=t.pre,n=void 0===i?r["default"]:i,o=t.post,s=void 0===o?r["default"]:o;return function(t){return{pipe:e}}}Object.defineProperty(e,"__esModule",{value:!0}),e["default"]=i}),define("src/proxy/responsibility",["require","exports","src/lib/noop"],function(t,e,r){"use strict";function i(){function t(t,i){return e.pipe=function(){for(var e=[],r=0;r<arguments.length;r++)e[r-0]=arguments[r];return e.map(function(e){return function(r){if(!(i(r)instanceof t))throw TypeError("ArchStream: ResponsibilityProxy: Uncovered internal entity: "+i(r).constructor);e(r)}})},e["export"]=function(){return function(e){i(e)instanceof t&&void Object.freeze(i(e))}},r["default"]}var e;return function(r){return e={rule:t}}}Object.defineProperty(e,"__esModule",{value:!0}),e["default"]=i}),define("src/lib/proxy",["require","exports","src/proxy/case","src/proxy/hook","src/proxy/responsibility"],function(t,e,r,i,n){"use strict";Object.defineProperty(e,"__esModule",{value:!0}),e["default"]={Case:r["default"],Hook:i["default"],Responsibility:n["default"]}}),define("src/lib/observable",["require","exports","src/lib/tick","src/lib/noop"],function(t,e,r,i){"use strict";var n=/$^/,o=function(){function t(t){void 0===t&&(t=n),this.separator_=t,this.map_=Object.create(null),this.emitOrder_=0,this.emitQueue_=[],this.drainFallbackable_=!1}return t.prototype.seek_=function(t,e){function r(t,e){return t[e]&&t[e].map?t[e]:t[e]={map:Object.create(null),list:[]}}switch(e.length){case 0:throw new Error("ArchStream: Observable: Cannot use empty string for event type and namespace.");case 1:return r(t,e.shift());default:return this.seek_(r(t,e.shift()).map,e)}},t.prototype.on=function(t,e){return void this.seek_(this.map_,t.toString().split(this.separator_)).list.push([e,0]),this},t.prototype.off=function(t,e){switch(typeof e){case"function":for(var r=this.seek_(this.map_,t.toString().split(this.separator_)).list,i=0;i<r.length;++i)if(r[i][0]===e){switch(i){case-1:break;case 0:void r.shift();break;default:void r.splice(i,1)}break}return this;case"undefined":var n=this.seek_(this.map_,t.toString().split(this.separator_));return n.map=Object.create(null),n.list=[],this;default:throw new TypeError("ArchStream: Observable: Invalid type argument: "+e)}},t.prototype.once=function(t,e){var r=this,i=function(n){void r.off(t,i),void e(n)};return void this.on(t,i),this},t.prototype.emit=function(t,e,r){void 0===r&&(r=i["default"]);var n=this.emitQueue_;return e instanceof Object&&void Object.freeze(e),void n.push([++this.emitOrder_,e,r]),this.drain_(t),this},t.prototype.drain_=function(t){function e(t){var r=t.map,i=t.list;return Object.keys(r).reduce(function(t,i){return void t.unshift.apply(t,e(r[i])),t},i.slice())}var i=this,n=this.emitQueue_;for(this.drainFallbackable_||(this.drainFallbackable_=!0,r["default"](function(){i.drainFallbackable_=!1,0!==i.emitQueue_.length&&i.drain_(t)}));n.length>0;){void e(this.seek_(this.map_,t.toString().split(this.separator_))).reduce(function(t,e){var r=t[0],i=t[1],n=e[0],o=e[1];return o>=r?t:(e[1]=r,void n(i),t)},n[0]);var o=n.shift(),s=o[1],u=o[2];void u(s)}return this},t}();Object.defineProperty(e,"__esModule",{value:!0}),e["default"]=o}),define("src/export",["require","exports","src/stream/transform","src/lib/message","src/lib/proxy","src/lib/tick","src/lib/observable"],function(t,e,r,i,n,o,s){"use strict";function u(){return new r["default"]}function c(){return new i["default"]}e.ArchStream=r["default"],e.Message=i["default"],e.Proxy=n["default"],e.Tick=o["default"],e.Observable=s["default"],Object.defineProperty(e,"__esModule",{value:!0}),e["default"]=u;var u,a={Msg:c,Proxy:n["default"],Tick:o["default"]};!function(t){t.Msg=a.Msg,t.Proxy=a.Proxy,t.Tick=a.Tick}(u||(u={})),e.Msg=c}),define("arch-stream",["require","exports","src/export","src/export"],function(t,e,r,i){"use strict";function n(t){for(var r in t)e.hasOwnProperty(r)||(e[r]=t[r])}n(r),e["default"]=i["default"]});
+/*! arch-stream v0.0.39 | (c) 2015, falsandtru | MIT Licence */
+define="function"==typeof define&&define.amd?define:function(){var t="arch-stream",e={};return function r(i,n,o){return o?void o.apply(this,n.map(function(t){switch(t){case"require":return"function"==typeof require?require:void 0;case"exports":return-1===i.indexOf("/")?e[i]="undefined"==typeof exports?window[i]=window[i]||{}:exports:e[i]=e.hasOwnProperty(i)?e[i]:{};default:return e[t]||"function"==typeof require&&require(t)||window[t]}})):void r(t,i,n)}}(),define("src/lib/thenable",["require","exports"],function(t,e){"use strict";function r(t){return!!t&&"object"==typeof t&&void 0!==t.then}e.isThenable=r}),define("src/lib/tick",["require","exports"],function(t,e){"use strict";var r;!function(t){function e(t){void n.push(t),void i()}function r(){void i(),void--o;for(var t=n.length;t-- >0;)void n.shift()()}function i(){if(0!==n.length)if(s)for(;2>o;)void Promise.resolve().then(r),void++o;else for(;o<u.length;)void setTimeout(r,u[o%u.length]),void++o}t.queue=e;var n=[],o=0,s="function"==typeof Promise,u=[0,4,10,20,25].reverse()}(r||(r={}));var i=Function("return typeof process === 'object' && typeof window !== 'object'")();Object.defineProperty(e,"__esModule",{value:!0}),e["default"]=i?Function("return fn => process.nextTick(fn)")():r.queue}),define("src/lib/message",["require","exports","src/lib/thenable","src/lib/tick"],function(t,e,r,i){"use strict";function n(t){return t}var o=Object.create(null),s=function(){function t(t,e){void 0===e&&(e=n),this.parent=t,this.listener=e,this.memory_=o,this.collection_=[],this.transform_=!1,this.listeners_=[],t&&(this.parent.child_=this)}return t.prototype.root=function(){return this.parent?this.parent.root():this},t.prototype.collect_=function(){if(this.collection_.length>0)return this.collection_;var t=this,e=[];do void e.push(t);while(t=t.child_);return this.collection_=e},t.prototype.transport_=function(t,e){function i(t,i,u){function c(t){return r.isThenable(t)?void t.then(c,c):(o=!0,i=u?t:i,void(s&&n.child_&&void n.child_.send(i,e)))}return t.every(function(t){n=t,n.memory_=i;var e=n.listener(n.memory_);return r.isThenable(e)?(o=!1,void e.then(c,c),o):(i=u?e:i,!0)})}var n,o=!1,s=!1,u=i(this.collect_(),t,this.transform_);s=!0,u&&"function"==typeof e&&void e(t)},t.prototype.clone=function(){function e(r){return r.parent?new t(e(r.parent),r.listener):new t(void 0,r.listener)}return e(this)},t.prototype.connect=function(t){return this.parent.child_=t,t.parent=this.parent,this},t.prototype.send=function(t,e,r){switch(!0){case"function"==typeof e:return this.send(t,!1,e);case e===!0:return void i["default"](this.transport_.bind(this,t,r)),this;case e===!1:default:return void this.transport_(t,r),this}},t.prototype.recv=function(e){var r=new t(this);return this.listener=e,this.collection_=[],this.memory_!==o&&void this.send(this.memory_),r},t.prototype.trans=function(t){return this.transform_=!0,this.recv(t)},t.prototype.then=function(e,r){var i=this,n=new t;return this.listeners_.push(n),this.trans(function(t){var e=i.listeners_;i.listeners_=[];for(var r=0;r<e.length;++r)e[r].send(t)}),n.trans(e)},t}();Object.defineProperty(e,"__esModule",{value:!0}),e["default"]=s}),define("src/lib/throttle",["require","exports"],function(t,e){"use strict";var r=function(){function t(){this.queue_=[],this.processing_=[],this.limit_=1/0,this.volume_=1/0}return t.prototype.isDrainable_=function(){return this.processing_.length<this.volume_},t.prototype.discharger_=function(t,e){},t.prototype.flow=function(t,e,r){void 0===e&&(e=1/0),void 0===r&&(r=function(){return null}),this.volume_=t,this.limit_=e,this.discharger_=r},t.prototype.enqueue=function(t){if(this.isDrainable_())return void this.processing_.push(t),void this.resolver_(t),!0;this.queue_.push(t);do void this.discharger_(this.queue_,this.processing_);while(this.processing_.length+this.queue_.length>this.limit_);return!1},t.prototype.dequeue=function(t){var e=this.processing_.indexOf(t);e>0?void this.processing_.splice(e,1):void this.processing_.shift(),this.queue_.length>0&&this.isDrainable_()&&void this.enqueue(this.queue_.shift())},t.prototype.register=function(t){this.resolver_=t},t}();Object.defineProperty(e,"__esModule",{value:!0}),e["default"]=r}),define("src/lib/noop",["require","exports"],function(t,e){"use strict";function r(){}Object.defineProperty(e,"__esModule",{value:!0}),e["default"]=r}),define("src/stream/modular",["require","exports","src/lib/throttle","src/lib/tick","src/lib/noop"],function(t,e,r,i,n){"use strict";var o=function(){function t(t,e,r){var n=this;void 0===e&&(e=1),this.procs=t,this.count=e,this.branched=r,this.read=this.read.bind(this),this.write=this.write.bind(this),void i["default"](function(t){return 0<n.count&&n.count<1/0&&n.throwCountDeprivedError()})}return t.prototype.compose_=function(){this.last_=this.procs.map(function(t){return t.clone()}).reduce(function(t,e){return t.connect(e.root())&&e}),this.first_=this.last_.root()},t.prototype.wrap=function(t){function e(e){return function(r){return t(r,e)}}void this.compose_();var r=this.last_;do r=r.parent,r.listener=e(r.listener);while(r.parent);return this.procs=[this.last_],this},t.prototype.read_=function(t){void--this.count,this.count<0&&void this.throwCountExceededError(),void this.compose_(),void this.last_.recv(t)},t.prototype.read=function(t){var e=this;void 0===t&&(t=n["default"]);var r=!1;return void this.read_(function(n){e.flow_&&void i["default"](function(){return void e.flow_.dequeue(n)}),r&&void t(n)}),r=!0,this},t.prototype.write_=function(t,e){void this.first_.send(t,e)},t.prototype.write=function(t,e){return this.flow_?void this.flow_.enqueue(t):void this.write_(t,e),this},t.prototype.flow=function(t,e,i){var n=this;return void 0===e&&(e=1/0),this.flow_=new r["default"],void this.flow_.flow(t,e,i),void this.flow_.register(function(t){return n.write_(t)}),this},t.prototype.throwCountExceededError=function(){throw new Error("ArchStream: Import and read counts are exeeded.")},t.prototype.throwCountDeprivedError=function(){throw this.count=0,new Error("ArchStream: Import and read counts are not deprived.")},t}();Object.defineProperty(e,"__esModule",{value:!0}),e["default"]=o}),define("src/stream/compose",["require","exports","src/stream/modular"],function(t,e,r){"use strict";var i=function(){function t(t){this.extract_=t,this.procs_=[],this.branched_=0}return t.prototype.register=function(t){var e=this.procs_.length;return void t.reduceRight(function(t,r,i){return t[i+e]=r,t},this.procs_),this},t.prototype["import"]=function(e,r){var i=this;return void this.throwErrorIfNotImportable_(e,r),r&&(e=(new t)["import"](e)["export"]().wrap(function(t,e){return i.extract_(t)instanceof r?e(t):0})),void--e.count,e.count<0&&void e.throwCountExceededError(),void this.register(e.procs),this},t.prototype["export"]=function(t){return new r["default"](this.procs_,t,this.branched_)},t.prototype.throwErrorIfNotImportable_=function(t,e){e?((t.branched>0||this.branched_>1)&&(void--t.count,void this.throwConditionalImportError()),this.branched_=1):(t.branched>0&&this.branched_>0&&(void--t.count,void this.throwConditionalImportError()),this.branched_=t.branched>0?t.branched+1:t.branched)},t.prototype.throwConditionalImportError=function(){throw new Error("ArchStream: Conditional import cannot call from different streams.")},t}();Object.defineProperty(e,"__esModule",{value:!0}),e["default"]=i}),define("src/stream/transform",["require","exports","src/lib/message","src/stream/compose","src/stream/modular"],function(t,e,r,i,n){"use strict";var o=function(){function t(t,e){var i=this;void 0===e&&(e=new r["default"]),this.parent_=t,this.message_=e,this.proxies_=[],this.parent_&&void this.parent_.proxies_.reduce(function(t,e){return i.proxy(e)},void 0)}return t.prototype.pipe=function(e){return new t(this,this.message_.recv(e))},t.prototype["import"]=function(t,e){return t instanceof n["default"]?(new i["default"])["import"](t,e):new i["default"](t)},t.prototype["export"]=function(t){return(new i["default"]).register([this.message_])["export"](t)},t.prototype.proxy=function(e){function r(e,i,n){function o(t){return Array.isArray(t)?t:[t]}var s=e.proxies_.filter(function(t){return"function"==typeof t[i]}).reduce(function(t,e){return o(e[i].apply(void 0,t)||t)},n),u="pipe";switch(i){case u:return t.prototype[i].call(e,s[0]);case"import":throw new Error("ArchStream: `import` method cannot extend by proxy.");case"export":return(c=t.prototype[i]).call.apply(c,[r(e,u,s)].concat(n));default:return r(e,u,s)}var c}var i=this,n="function"==typeof e?e():e;return this.proxies_.push(n),void Object.keys(n).filter(function(t){return t.length>0&&"_"!==t[0]&&"_"!==t[t.length-1]}).filter(function(t){return"function"==typeof n[t]}).reduce(function(t,e){return i[e]=function(){for(var t=[],n=0;n<arguments.length;n++)t[n-0]=arguments[n];return r(i,e,t)}},void 0),this},t}();Object.defineProperty(e,"__esModule",{value:!0}),e["default"]=o}),define("src/proxy/case",["require","exports"],function(t,e){"use strict";function r(t,e){function r(){for(var t=[],r=0;r<arguments.length;r++)t[r-0]=arguments[r];return function(r){var n=+i[e(r)+""];n>-1&&n<t.length&&t[n](r)}}var i=Object.create(null);return void t.reduce(function(t,e,r){return i[e+""]=r},void 0),function(t){return{pipe:r}}}Object.defineProperty(e,"__esModule",{value:!0}),e["default"]=r}),define("src/proxy/hook",["require","exports","src/lib/noop"],function(t,e,r){"use strict";function i(t){function e(){for(var t=[],e=0;e<arguments.length;e++)t[e-0]=arguments[e];return t.map(function(t){return function(e){n(e),t(e),s(e)}})}var i=t.pre,n=void 0===i?r["default"]:i,o=t.post,s=void 0===o?r["default"]:o;return function(t){return{pipe:e}}}Object.defineProperty(e,"__esModule",{value:!0}),e["default"]=i}),define("src/proxy/responsibility",["require","exports","src/lib/noop"],function(t,e,r){"use strict";function i(){function t(t,i){return e.pipe=function(){for(var e=[],r=0;r<arguments.length;r++)e[r-0]=arguments[r];return e.map(function(e){return function(r){if(!(i(r)instanceof t))throw TypeError("ArchStream: ResponsibilityProxy: Uncovered internal entity: "+i(r).constructor);e(r)}})},e["export"]=function(){return function(e){i(e)instanceof t&&void Object.freeze(i(e))}},r["default"]}var e;return function(r){return e={rule:t}}}Object.defineProperty(e,"__esModule",{value:!0}),e["default"]=i}),define("src/lib/proxy",["require","exports","src/proxy/case","src/proxy/hook","src/proxy/responsibility"],function(t,e,r,i,n){"use strict";Object.defineProperty(e,"__esModule",{value:!0}),e["default"]={Case:r["default"],Hook:i["default"],Responsibility:n["default"]}}),define("src/lib/observable",["require","exports","src/lib/tick","src/lib/noop"],function(t,e,r,i){"use strict";var n=/$^/,o=function(){function t(t){void 0===t&&(t=n),this.separator_=t,this.map_=Object.create(null),this.emitOrder_=0,this.emitQueue_=[],this.drainFallbackable_=!1}return t.prototype.seek_=function(t,e){function r(t,e){return t[e]&&t[e].map?t[e]:t[e]={map:Object.create(null),list:[]}}switch(e.length){case 0:throw new Error("ArchStream: Observable: Cannot use empty string for event type and namespace.");case 1:return r(t,e.shift());default:return this.seek_(r(t,e.shift()).map,e)}},t.prototype.on=function(t,e){return void this.seek_(this.map_,t.toString().split(this.separator_)).list.push([e,0]),this},t.prototype.off=function(t,e){switch(typeof e){case"function":for(var r=this.seek_(this.map_,t.toString().split(this.separator_)).list,i=0;i<r.length;++i)if(r[i][0]===e){switch(i){case-1:break;case 0:void r.shift();break;default:void r.splice(i,1)}break}return this;case"undefined":var n=this.seek_(this.map_,t.toString().split(this.separator_));return n.map=Object.create(null),n.list=[],this;default:throw new TypeError("ArchStream: Observable: Invalid type argument: "+e)}},t.prototype.once=function(t,e){var r=this,i=function(n){void r.off(t,i),void e(n)};return void this.on(t,i),this},t.prototype.emit=function(t,e,r){void 0===r&&(r=i["default"]);var n=this.emitQueue_;return e instanceof Object&&void Object.freeze(e),void n.push([++this.emitOrder_,e,r]),this.drain_(t),this},t.prototype.drain_=function(t){function e(t){var r=t.map,i=t.list;return Object.keys(r).reduce(function(t,i){return void t.unshift.apply(t,e(r[i])),t},i.slice())}var i=this,n=this.emitQueue_;for(this.drainFallbackable_||(this.drainFallbackable_=!0,r["default"](function(){i.drainFallbackable_=!1,0!==i.emitQueue_.length&&i.drain_(t)}));n.length>0;){void e(this.seek_(this.map_,t.toString().split(this.separator_))).reduce(function(t,e){var r=t[0],i=t[1],n=e[0],o=e[1];return o>=r?t:(e[1]=r,void n(i),t)},n[0]);var o=n.shift(),s=o[1],u=o[2];void u(s)}return this},t}();Object.defineProperty(e,"__esModule",{value:!0}),e["default"]=o}),define("src/export",["require","exports","src/stream/transform","src/lib/message","src/lib/proxy","src/lib/tick","src/lib/observable"],function(t,e,r,i,n,o,s){"use strict";function u(){return new r["default"]}function c(){return new i["default"]}e.ArchStream=r["default"],e.Message=i["default"],e.Proxy=n["default"],e.Tick=o["default"],e.Observable=s["default"],Object.defineProperty(e,"__esModule",{value:!0}),e["default"]=u;var u,a={Msg:c,Proxy:n["default"],Tick:o["default"]};!function(t){t.Msg=a.Msg,t.Proxy=a.Proxy,t.Tick=a.Tick}(u||(u={})),e.Msg=c}),define("arch-stream",["require","exports","src/export","src/export"],function(t,e,r,i){"use strict";function n(t){for(var r in t)e.hasOwnProperty(r)||(e[r]=t[r])}n(r),e["default"]=i["default"]});

gulpfile.js

@@ -72,25 +72,29 @@ const gulp = require('gulp');
   exporter:
-`define = typeof define === "function"
+`define = typeof define === "function" && define.amd
   ? define
-  : function (m, rs, f) {
-    if (!f) return define(m[2], m, rs);
-    var ns = define['@${pkg.name}'] = define['@${pkg.name}'] || {};
-    f.apply(this,
-      rs.map(function (r) {
-        switch (r) {
-          case 'require': {
-            return typeof require === 'function' ? require : void 0;
+  : (function () {
+    var package = '${pkg.name}',
+        workspace = {};
+    return function define(m, rs, f) {
+      return !f
+        ? void define(package, m, rs)
+        : void f.apply(this, rs.map(function (r) {
+          switch (r) {
+            case 'require': {
+              return typeof require === 'function' ? require : void 0;
+            }
+            case 'exports': {
+              return m.indexOf('/') === -1
+                ? workspace[m] = typeof exports === 'undefined' ? window[m] = window[m] || {} : exports
+                : workspace[m] = workspace.hasOwnProperty(m) ? workspace[m] : {};
+            }
+            default: {
+              return workspace[r]
+                  || typeof require === 'function' && require(r)
+                  || window[r];
+            }
           }
-          case 'exports': {
-            return m.indexOf('/') === -1
-              ? ns[m] = typeof exports === 'undefined' ? window[m] = window[m] || {} : exports
-              : ns[m] = ns.hasOwnProperty(m) ? ns[m] : {};
-          }
-          default: {
-            return ns[r];
-          }
-        }
-      })
-    );
-  };
+        }));
+    };
+  })();
 `,
@@ -97,0 +101,0 @@ clean: {

package.json

 {
   "name": "arch-stream",
-  "version": "0.0.38",
+  "version": "0.0.39",
   "description": "Pipeline stream for software architecture of Domain-Driven Design and Data-Oriented Design.",
@@ -64,3 +64,3 @@ "private": false,
     "tslint": "^3.1.1",
-    "typescript": "^1.8.0-dev.20151213"
+    "typescript": "1.8.0-dev.20151213"
   },
@@ -67,0 +67,0 @@ "engines": {

New alerts

Dynamic require

Supply chain risk

Dynamic require can indicate the package is performing dangerous or unsafe dynamic code execution.

Found 1 instance in 1 package

Improved metrics

Total package byte prevSize

154121

increased by0.32%

Lines of code

3421

increased by0.23%

Worsened metrics

Number of low supply chain risk alerts

6

increased by50%

No dependency changes