arch-stream - npm Package Compare versions

Comparing version 0.0.9 to 0.0.10

CHANGELOG.md

 # Changelog
 
+## 0.0.10
+
+Update
+
 ## 0.0.9
@@ -4,0 +8,0 @@

dist/arch-stream.js

@@ -1,2 +0,2 @@
-/*! arch-stream v0.0.9 | (c) 2015, falsandtru | MIT Licence */
+/*! arch-stream v0.0.10 | (c) 2015, falsandtru | MIT Licence */
 require=(function e(t,n,r){function s(o,u){if(!n[o]){if(!t[o]){var a=typeof require=="function"&&require;if(!u&&a)return a(o,!0);if(i)return i(o,!0);var f=new Error("Cannot find module '"+o+"'");throw f.code="MODULE_NOT_FOUND",f}var l=n[o]={exports:{}};t[o][0].call(l.exports,function(e){var n=t[o][1][e];return s(n?n:e)},l,l.exports,e,t,n,r)}return n[o].exports}var i=typeof require=="function"&&require;for(var o=0;o<r.length;o++)s(r[o]);return s})({1:[function(_dereq_,module,exports){
@@ -3,0 +3,0 @@ 'use strict';

dist/arch-stream.min.js

@@ -1,2 +0,2 @@
-/*! arch-stream v0.0.9 | (c) 2015, falsandtru | MIT Licence */
+/*! arch-stream v0.0.10 | (c) 2015, falsandtru | MIT Licence */
 require=function t(e,r,n){function o(u,s){if(!r[u]){if(!e[u]){var c="function"==typeof require&&require;if(!s&&c)return c(u,!0);if(i)return i(u,!0);var f=new Error("Cannot find module '"+u+"'");throw f.code="MODULE_NOT_FOUND",f}var p=r[u]={exports:{}};e[u][0].call(p.exports,function(t){var r=e[u][1][t];return o(r?r:t)},p,p.exports,t,e,r,n)}return r[u].exports}for(var i="function"==typeof require&&require,u=0;u<n.length;u++)o(n[u]);return o}({1:[function(t,e,r){"use strict";function n(t,e,r){t[e]=t[e].bind(t)}Object.defineProperty(r,"__esModule",{value:!0}),r["default"]=n},{}],2:[function(t,e,r){"use strict";function n(t){return t}function o(t){return!!t&&"object"==typeof t&&"then"in t}var i=this&&this.__decorate||function(t,e,r,n){if("object"==typeof Reflect&&"function"==typeof Reflect.decorate)return Reflect.decorate(t,e,r,n);switch(arguments.length){case 2:return t.reduceRight(function(t,e){return e&&e(t)||t},e);case 3:return t.reduceRight(function(t,n){return void(n&&n(e,r))},void 0);case 4:return t.reduceRight(function(t,n){return n&&n(e,r,t)||t},n)}},u=t("./tick"),s=t("../decorator/bind"),c={},f=function(){function t(t,e){void 0===e&&(e=n),this.parent_=t,this.listener_=e,this.memory_=c,t&&(this.parent_.child_=this)}return t.prototype.root=function(){return this.parent_?this.parent_.root():this},t.prototype.collect_=function(){var t=this,e=[];do e.push(t),t=t.child_;while(t);return this.collection_=e,e},t.prototype.trampoline_=function(t){for(var e=this.collection_?this.collection_:this.collect_(),r=!1,n=0;n<e.length;n++){var i=e[n];i.memory_=t;var u=i.listener_(t);if(o(u)){var s=!1,c=c||function(){s=!0,r&&i.child_&&i.child_.trampoline_(t)};if(u.then(c,c),!s)break}}r=!0},t.prototype.clone_=function(e){return e.parent_?new t(this.clone_(e.parent_),e.listener_):new t(void 0,e.listener_)},t.prototype.clone=function(){return this.clone_(this)},t.prototype.connect=function(t){return this.parent_.child_=t,t.parent_=this.parent_,this},t.prototype.send=function(t,e){return e?u["default"](this.trampoline_.bind(this,t)):this.trampoline_(t),this},t.prototype.recv=function(e){this.listener_=e,this.collection_=void 0;var r=new t(this);return this.memory_!==c&&this.send(this.memory_),r},t.prototype.then=function(t,e){return this.recv(t)},Object.defineProperty(t.prototype,"send",i([s["default"]],t.prototype,"send",Object.getOwnPropertyDescriptor(t.prototype,"send"))),Object.defineProperty(t.prototype,"recv",i([s["default"]],t.prototype,"recv",Object.getOwnPropertyDescriptor(t.prototype,"recv"))),t}();Object.defineProperty(r,"__esModule",{value:!0}),r["default"]=f},{"../decorator/bind":1,"./tick":5}],3:[function(t,e,r){"use strict";var n=t("../proxy/case"),o=t("../proxy/hook"),i=t("../proxy/responsibility");Object.defineProperty(r,"__esModule",{value:!0}),r["default"]={Case:n["default"],Hook:o["default"],Responsibility:i["default"]}},{"../proxy/case":6,"../proxy/hook":7,"../proxy/responsibility":8}],4:[function(t,e,r){"use strict";var n=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 this.processing_.push(t),this.resolver_(t),!0;this.queue_.push(t);do 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?this.processing_.splice(e,1):this.processing_.shift(),this.queue_.length>0&&this.isDrainable_()&&this.enqueue(this.queue_.shift())},t.prototype.register=function(t){this.resolver_=t},t}();Object.defineProperty(r,"__esModule",{value:!0}),r["default"]=n},{}],5:[function(t,e,r){"use strict";var n;!function(t){function e(t){i.push(t),n()}function r(){--u,n();for(var t=i.length;t-->0;)i.shift()()}function n(){if(0!==i.length)if(o)for(;2>u;)Promise.resolve().then(r),++u;else for(;u<s.length;)setTimeout(r,s[u%s.length]),++u}t.queue=e;var o="function"==typeof Promise,i=[],u=0,s=[0,4,10,20,25].reverse()}(n||(n={}));var o=Function("return typeof process === 'object' && typeof window !== 'object'")();Object.defineProperty(r,"__esModule",{value:!0}),r["default"]=o?Function("return fn => process.nextTick(fn)")():n.queue},{}],6:[function(t,e,r){"use strict";function n(t){function e(){for(var t=[],e=0;e<arguments.length;e++)t[e-0]=arguments[e];return function(e){var r=+o[n(e)];return r>-1&&r<t.length?t[r](e):t}}var r=t.index,n=t.indexer,o=Object.create(null);return r.forEach(function(t,e){return o[t]=e}),function(t){return{pipe:e}}}Object.defineProperty(r,"__esModule",{value:!0}),r["default"]=n},{}],7:[function(t,e,r){"use strict";function n(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),u(e)}})}var r=t.pre,n=void 0===r?o:r,i=t.post,u=void 0===i?o:i;return function(t){return{pipe:e}}}function o(){}Object.defineProperty(r,"__esModule",{value:!0}),r["default"]=n},{}],8:[function(t,e,r){"use strict";function n(){function t(t,r){var n=e.pipe;return e.pipe=function(){for(var e=[],o=0;o<arguments.length;o++)e[o-0]=arguments[o];var i=n&&n.apply(void 0,e)[0];return e.map(function(e){return function(o){return r(o)instanceof t?(n?i:e)(o):e}})},o}var e;return function(r){return e={rule:t}}}function o(){}Object.defineProperty(r,"__esModule",{value:!0}),r["default"]=n},{}],9:[function(t,e,r){"use strict";var n=t("./modular"),o=function(){function t(t){this.procs_=[],t&&this.register_([t])}return t.prototype.register_=function(t){for(var e=this.procs_,r=this.procs_.length,n=t.length;n--;)e[n+r]=t[n]},t.prototype["import"]=function(t){return--t.count<0&&t.throwCountExceededError(),this.register_(t.procs),this},t.prototype["export"]=function(t){return new n["default"](this.procs_,t)},t}();Object.defineProperty(r,"__esModule",{value:!0}),r["default"]=o},{"./modular":10}],10:[function(t,e,r){"use strict";var n=t("../lib/throttle"),o=t("../lib/tick"),i=function(){function t(t,e){var r=this;void 0===e&&(e=1),this.procs=t,this.count=e,o["default"](function(t){return 0<r.count&&r.count<1/0&&r.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.throwCountExceededError=function(){throw new Error("Import and read counts are exeeded.")},t.prototype.throwCountDeprivedError=function(){throw this.count=0,new Error("Import and read counts are not deprived.")},t.prototype.flow=function(t,e,r){var o=this;return void 0===e&&(e=1/0),this.flow_=new n["default"],this.flow_.flow(t,e,r),this.flow_.register(function(t){return o.write_(t)}),this},t.prototype.read_=function(t){--this.count<0&&this.throwCountExceededError(),this.compose_(),this.last_.recv(t)},t.prototype.read=function(t){var e=this,r=!1;return this.read_(function(n){e.flow_&&o["default"](function(){return e.flow_.dequeue(n)}),r&&t(n)}),r=!0,this},t.prototype.write_=function(t){this.first_.send(t)},t.prototype.write=function(t){return this.flow_?this.flow_.enqueue(t):this.write_(t),this},t}();Object.defineProperty(r,"__esModule",{value:!0}),r["default"]=i},{"../lib/throttle":4,"../lib/tick":5}],11:[function(t,e,r){"use strict";var n=t("../lib/message"),o=t("./compose"),i=function(){function t(t,e,r){var o=this;void 0===e&&(e=new n["default"]),void 0===r&&(r=[]),this.parent_=t,this.message_=e,this.proxies_=[],this.parent_&&r.unshift.apply(r,t.proxies_),r.forEach(function(t){return o.proxy(t)})}return t.prototype.proxy_=function(e,r){function n(t){return Array.isArray(t)?t:[t]}var o=this.proxies_.filter(function(t){return"function"==typeof t[e]}).reduce(function(t,r){return n(r[e].apply(r,t))},r);return"export"!==e?t.prototype.pipe.call(this,o[0]):t.prototype.pipe.call(this,o[0])["export"]()},t.prototype.proxy=function(t){var e=this,r="function"==typeof t?t():t;return this.proxies_.push(r),Object.keys(r).filter(function(t){return"function"==typeof r[t]}).forEach(function(t){return e[t]=function(){for(var r=[],n=0;n<arguments.length;n++)r[n-0]=arguments[n];return e.proxy_(t,r)}}),this},t.prototype.pipe=function(e){return new t(this,this.message_.recv(e))},t.prototype["import"]=function(t){return(new o["default"])["import"](t)},t.prototype["export"]=function(t){return new o["default"](this.message_)["export"](t)},t}();Object.defineProperty(r,"__esModule",{value:!0}),r["default"]=i},{"../lib/message":2,"./compose":9}],"arch-stream":[function(t,e,r){"use strict";function n(){return new i["default"]}function o(){return new u["default"]}var n,i=t("./stream/transform"),u=t("./lib/message"),s=t("./lib/proxy"),c=t("./lib/tick"),f={"default":n,Msg:o,Proxy:s["default"],Tick:c["default"],ArchStream:i["default"],Message:u["default"]};!function(t){t.Msg=f.Msg,t.Proxy=f.Proxy,t.Tick=f.Tick}(n||(n={})),e.exports=f},{"./lib/message":2,"./lib/proxy":3,"./lib/tick":5,"./stream/transform":11}]},{},[1,"arch-stream",2,3,4,5,6,7,8,9,10,11]),"object"==typeof module&&module&&"exports"in module&&(module.exports=require("arch-stream"));

gulpfile.js

@@ -27,2 +27,6 @@ const gulp = require('gulp');
     }),
+    typings: {
+      src: pkg.typings || 'index.d.ts',
+      dest: 'typings/local/'
+    },
     source: {
@@ -34,3 +38,2 @@ lint: {
         'typings/*.d.ts',
-        'typings/local/*.d.ts',
         'src/**/*.ts'
@@ -46,3 +49,2 @@ ],
         'typings/*.d.ts',
-        'typings/local/*.d.ts',
         'src/**/+([!.]).ts'
@@ -161,2 +163,12 @@ ],
 
+gulp.task('ts:typings', function () {
+  return gulp.src(config.ts.typings.src)
+    .pipe($.tslint(config.ts.source.lint))
+    .pipe($.tslint.report('prose', { emitError: false }))
+    .pipe($.replace(/declare /g, ''))
+    .pipe($.header(`declare module "${ pkg.name }" {\n`))
+    .pipe($.footer('}\n'))
+    .pipe(gulp.dest(config.ts.typings.dest));
+});
+
 gulp.task('ts:source', function () {
@@ -196,2 +208,3 @@ return gulp.src(config.ts.source.src)
   const cmd = `node node_modules/typescript/lib/tsc.js -t ${config.ts.options.target} -m ${config.ts.options.module} -w`;
+  gulp.watch(config.ts.typings.src, ['ts:typings']);
   glob(config.ts.source.src, function (_, files) {
@@ -288,2 +301,3 @@ spawn(cmd + ` ${files.join(' ')}`);
   seq(
+    'ts:typings',
     ['ts:source', 'ts:test'],
@@ -290,0 +304,0 @@ ['browserify:source'],

package.json

 {
   "name": "arch-stream",
-  "version": "0.0.9",
+  "version": "0.0.10",
   "description": "Modular stream for domain and data oriented program architecture design.",
@@ -22,2 +22,3 @@ "private": false,
     "dist",
+    "index.*",
     "typings",
@@ -47,2 +48,3 @@ "src",
     "gulp-rename": "^1.2.2",
+    "gulp-replace": "^0.5.4",
     "gulp-tslint": "^3.3.1",
@@ -49,0 +51,0 @@ "gulp-typescript": "^2.9.2",

src/lib/message.ts

@@ -1,2 +0,2 @@
-import { Message as IMessage, ICallback } from 'arch-stream';
+import { Message as IMessage, ICallback } from '../../';
 import Tick from './tick';
@@ -3,0 +3,0 @@ import bind from '../decorator/bind';

src/proxy/case.ts

@@ -1,2 +0,2 @@
-import { ICallback, ITransformStream } from 'arch-stream';
+import { ICallback, ITransformStream } from '../../';
 
@@ -3,0 +3,0 @@ interface CaseProxy<T, U> {

src/proxy/hook.ts

@@ -1,2 +0,2 @@
-import { ICallback, ITransformStream } from 'arch-stream';
+import { ICallback, ITransformStream } from '../../';
 
@@ -3,0 +3,0 @@ interface HookProxy<T, U> {

src/proxy/responsibility.ts

@@ -1,2 +0,2 @@
-import { ICallback, ITransformStream } from 'arch-stream';
+import { ICallback, ITransformStream } from '../../';
 
@@ -3,0 +3,0 @@ interface ResponsibilityProxy<T, U> {

src/stream/compose.ts

@@ -1,2 +0,2 @@
-import { IComposeStream } from 'arch-stream';
+import { IComposeStream } from '../../';
 import ModularStream from './modular';
@@ -3,0 +3,0 @@ import Message from '../lib/message';

src/stream/modular.ts

@@ -1,2 +0,2 @@
-import { IModularStream, IModularWritableStream, IModularReadableStream, ICallback } from 'arch-stream';
+import { IModularStream, IModularWritableStream, IModularReadableStream, ICallback } from '../../';
 import Message from '../lib/message';
@@ -3,0 +3,0 @@ import Throttle from '../lib/throttle';

src/stream/transform.ts

@@ -1,2 +0,2 @@
-import { ArchStream as IArchStream, ITransformStream, ICallback } from 'arch-stream';
+import { ArchStream as IArchStream, ITransformStream, ICallback } from '../../';
 import Message from '../lib/message';
@@ -3,0 +3,0 @@ import ComposeStream from './compose';

No alert changes

Improved metrics

Total package byte prevSize

132263

increased by2.67%

Number of package files

58

increased by1.75%

Lines of code

3162

increased by2.83%

Worsened metrics

Dev dependency count

38

increased by2.7%

No dependency changes