@cycle/time - npm Package Compare versions

Comparing version 0.12.0 to 0.13.0

CHANGELOG.md

@@ -0,1 +1,13 @@
+<a name="0.13.0"></a>
+# 0.13.0 (2018-02-16)
+
+
+### Bug Fixes
+
+* **time:** fix event processing ([#771](https://github.com//cyclejs/cyclejs/issues/771)) ([2361c00](https://github.com/cyclejs/cyclejs/commit/2361c00))
+* **time:** fix rxjs and most entrypoints ([c31b60d](https://github.com/cyclejs/cyclejs/commit/c31b60d))
+* **time:** fix throttle immediately completing with sync producer ([3bb2271](https://github.com/cyclejs/cyclejs/commit/3bb2271)), closes [#770](https://github.com/cyclejs/cyclejs/issues/770)
+
+
+
 <a name="0.12.0"></a>
@@ -2,0 +14,0 @@ # 0.12.0 (2017-12-28)

dist/cycle-time.min.js

@@ -39,3 +39,3 @@ /*
 b.unexpectedErrors.push(h.error)))}});0===n.length?b.state="passed":(b.state="failed",b.error=Error(k("\nExpected\n\n"+h(a.expected,c)+"\n\nGot\n\n"+h(a.actual,c)+"\n\nFailed because:\n\n"+n.map(function(a){return" * "+a}).join("\n")+"\n\n"+r(b.unexpectedErrors)+"\n    ")))}function d(a,b){for(var c=0;c<a.length;)a[c]=b,c++;return a}function b(a,b){return a.reduce(function(a,c){var d=a.items;a=a.previousValue;var l=b(c);if(l!==a)return{items:d.concat([[c]]),previousValue:l};l=d[d.length-1];return{items:d.slice(0,
--1).concat([l.concat(c)]),previousValue:a}},{items:[],previousValue:void 0}).items}function w(a){if("next"===a.type)return a=a.value,a="object"===typeof a?JSON.stringify(a):a,a;if("complete"===a.type)return"|";if("error"===a.type)return"#"}function h(a,c){if(0===a.length)return"\x3cempty stream\x3e";var n=Math.max.apply(Math,a.map(function(a){return a.time})),l=d(Array(Math.ceil(n/c)),"-");b(a,function(a){return Math.max(0,Math.floor(a.time/c))}).forEach(function(a){var b=Math.max(0,Math.floor(a[0].time/
+-1).concat([l.concat(c)]),previousValue:a}},{items:[],previousValue:void 0}).items}function w(a){if("next"===a.type)return a=a.value,a="object"===typeof a?JSON.stringify(a):a,a;if("complete"===a.type)return"|";if("error"===a.type)return"#"}function h(a,c){if(0===a.length)return"\x3cempty stream\x3e";var h=Math.max.apply(Math,a.map(function(a){return a.time})),l=d(Array(Math.ceil(h/c)),"-");b(a,function(a){return Math.max(0,Math.floor(a.time/c))}).forEach(function(a){var b=Math.max(0,Math.floor(a[0].time/
 c));1===a.length?l[b]=w(a[0]):["("].concat(a.map(w),[")"]).forEach(function(a,c){l[b+c]=a})});return l.join("")}function k(a){return a.split("\n").map(function(a){return a.replace(/^\s{12}/,"")}).join("\n")}function r(a){return 0===a.length?"":"Unexpected error:\n "+a.map(function(a){return a.stack}).join("\n \n ")}Object.defineProperty(f,"__esModule",{value:!0});var c="undefined"!==typeof window?window.xstream:"undefined"!==typeof a?a.xstream:null,p=e("assert"),g=e("variable-diff");f.makeAssertEqual=
@@ -51,3 +51,3 @@ function(a,b,d,l,h){return function(b,d,n){void 0===n&&(n=p.deepEqual);var k={},e=a(),f={state:"pending",error:null,unexpectedErrors:[],finish:function(){m(k,f,l,n)}};h(f);b=e.record(b);d=e.record(d);c.default.combine(c.default.fromObservable(b),c.default.fromObservable(d)).addListener({next:function(a){var b=a[1];k.actual=a[0];k.expected=b},complete:function(){m(k,f,l,n)}})}}}).call(this,"undefined"!==typeof global?global:"undefined"!==typeof self?self:"undefined"!==typeof window?window:{})},{assert:1,
 a);void 0===c&&(c=0);J=b;c||(c=x);B.runVirtually(F,function(){return m(I,J)},e,n,c)},createOperator:f,_scheduler:F.add,_time:e};return H}},{"./assert-equal":8,"./debounce":9,"./delay":10,"./diagram":11,"./periodic":13,"./record":14,"./run-virtually":15,"./scheduler":16,"./throttle":18,"./throttle-animation":17,"combine-errors":24}],13:[function(e,g,f){(function(a){Object.defineProperty(f,"__esModule",{value:!0});var m="undefined"!==typeof window?window.xstream:"undefined"!==typeof a?a.xstream:null,
-d=e("@cycle/run/lib/adapt");f.makePeriodic=function(a){a=a();var b=a.schedule,e=a.currentTime;return function(a){function h(b,d,e,l){c||(e.next(b.stream,k+a,b.value+1,h),k+=a)}var c=!1,k=0,f={listener:null,start:function(c){f.listener=c;var d=e()+a;b.next(c,d,0,h);k=d},stop:function(){c=!0;f.listener.complete()}};return d.adapt(m.default.create(f))}}}).call(this,"undefined"!==typeof global?global:"undefined"!==typeof self?self:"undefined"!==typeof window?window:{})},{"@cycle/run/lib/adapt":20}],14:[function(e,
+d=e("@cycle/run/lib/adapt");f.makePeriodic=function(a){a=a();var b=a.schedule,h=a.currentTime;return function(a){function e(b,d,h,l){c||(h.next(b.stream,k+a,b.value+1,e),k+=a)}var c=!1,k=0,f={listener:null,start:function(c){f.listener=c;var d=h()+a;b.next(c,d,0,e);k=d},stop:function(){c=!0;f.listener.complete()}};return d.adapt(m.default.create(f))}}}).call(this,"undefined"!==typeof global?global:"undefined"!==typeof self?self:"undefined"!==typeof window?window:{})},{"@cycle/run/lib/adapt":20}],14:[function(e,
 g,f){(function(a){function m(a,b){var d=[];b.next(d);return{next:function(e){d=d.concat({type:"next",value:e,time:a()});b.next(d)},error:function(e){d=d.concat({type:"error",time:a(),error:e});b.next(d);b.complete()},complete:function(){d=d.concat({type:"complete",time:a()});b.next(d);b.complete()}}}Object.defineProperty(f,"__esModule",{value:!0});var d="undefined"!==typeof window?window.xstream:"undefined"!==typeof a?a.xstream:null,b=e("@cycle/run/lib/adapt");f.makeRecord=function(a,e,f){return function(a){var c=
@@ -58,7 +58,7 @@ d.default.createWithMemory({start:function(b){d.default.fromObservable(a).addListener(m(e,b))},stop:function(){}});return b.adapt(c)}}}).call(this,"undefined"!==typeof global?global:"undefined"!==typeof self?self:"undefined"!==typeof window?window:{})},{"@cycle/run/lib/adapt":20}],15:[function(e,g,f){function a(e){var d=e.scheduler,b=e.done,f=e.currentTime,h=e.setTime,k=e.timeToRunTo,m=d.peek(),k=m&&k&&m.time>=k;!m||k?b():(b=d.shiftNextEntry(),b.cancelled||(m=b.time,h(m),b.f&&b.f(b,m,d.add,f),"next"===
 stream:a,time:e,value:c,f:h})},error:function(a,b,c){return d({type:"error",stream:a,time:b,error:c})},complete:function(a,b){return d({type:"complete",stream:a,time:b})}}}}},{"sorted-immutable-list":41}],17:[function(e,g,f){(function(a){Object.defineProperty(f,"__esModule",{value:!0});var m="undefined"!==typeof window?window.xstream:"undefined"!==typeof a?a.xstream:null,d=e("@cycle/run/lib/adapt");f.makeThrottleAnimation=function(a,e,h){return function(b){var e=a(),c=m.default.create({start:function(a){var c=
-null,d=!0,h=m.default.fromObservable(e.animationFrames()),n={next:function(b){d||(a.next(c),d=!0)}};m.default.fromObservable(b).addListener({next:function(a){c=a;d=!1},error:function(b){a.error(b)},complete:function(){h.removeListener(n);a.complete()}});h.addListener(n)},stop:function(){}});return d.adapt(c)}}}).call(this,"undefined"!==typeof global?global:"undefined"!==typeof self?self:"undefined"!==typeof window?window:{})},{"@cycle/run/lib/adapt":20}],18:[function(e,g,f){(function(a){function m(a,
-b,d,e,c){return{next:function(h){var f=c.lastEventTime,m=b();m-f<=d||(a.next(e,m,h),c.lastEventTime=m)},error:function(a){e.error(a)},complete:function(){e.complete()}}}Object.defineProperty(f,"__esModule",{value:!0});var d="undefined"!==typeof window?window.xstream:"undefined"!==typeof a?a.xstream:null,b=e("@cycle/run/lib/adapt");f.makeThrottle=function(a){a=a();var e=a.schedule,f=a.currentTime;return function(a){return function(c){var h={lastEventTime:-Infinity},k=d.default.create({start:function(b){b=
+null,d=!0,h=m.default.fromObservable(e.animationFrames()),f={next:function(b){d||(a.next(c),d=!0)}};m.default.fromObservable(b).addListener({next:function(a){c=a;d=!1},error:function(b){a.error(b)},complete:function(){h.removeListener(f);a.complete()}});h.addListener(f)},stop:function(){}});return d.adapt(c)}}}).call(this,"undefined"!==typeof global?global:"undefined"!==typeof self?self:"undefined"!==typeof window?window:{})},{"@cycle/run/lib/adapt":20}],18:[function(e,g,f){(function(a){function m(a,
+b,d,e,c){return{next:function(h){var f=c.lastEventTime,m=b();m-f<=d||(a.next(e,m,h),c.lastEventTime=m)},error:function(a){e.error(a)},complete:function(){a.complete(e,b())}}}Object.defineProperty(f,"__esModule",{value:!0});var d="undefined"!==typeof window?window.xstream:"undefined"!==typeof a?a.xstream:null,b=e("@cycle/run/lib/adapt");f.makeThrottle=function(a){a=a();var e=a.schedule,f=a.currentTime;return function(a){return function(c){var h={lastEventTime:-Infinity},k=d.default.create({start:function(b){b=
 m(e,f,a,b,h);d.default.fromObservable(c).addListener(b)},stop:function(){}});return b.adapt(k)}}}}).call(this,"undefined"!==typeof global?global:"undefined"!==typeof self?self:"undefined"!==typeof window?window:{})},{"@cycle/run/lib/adapt":20}],19:[function(e,g,f){function a(a){for(var b=[];0<a.length;)b.push(a.pop());return b}function m(b,c,d,e){function h(b){f||(e(b),a(c).forEach(function(a){return a(b)}));t(h)}var f=!1;t(h);setInterval(function(){if(!f){var a=z();e(a);if(!b.isEmpty())for(var c=
-b.peek().time;c<a;){c=b.shiftNextEntry();if(!c.cancelled)throw c.f&&c.f(c,a,b.add,d),"next"===c.type&&c.stream.shamefullySendNext(c.value),"complete"===c.type&&c.stream.shamefullySendComplete(),"error"===c.type&&c.stream.shamefullySendError(c.error),Error("Unhandled event type: "+c.type);c=b.peek()&&b.peek().time||Infinity}}},10);return{pause:function(){return f=!0},resume:function(a){e(a);f=!1}}}Object.defineProperty(f,"__esModule",{value:!0});var d=e("./scheduler"),b=e("./delay"),w=e("./debounce"),
-h=e("./periodic"),k=e("./throttle"),r=e("./animation-frames"),c=e("./throttle-animation"),p=e("./run-virtually"),t=e("raf"),z=e("performance-now");f.timeDriver=function(a){function e(){return v}function f(a){v=a}function g(){return{schedule:z.add,currentTime:e}}var v=0,t=[],z=d.makeScheduler(),x=m(z,t,e,f);a=x.pause;var x=x.resume,B={animationFrames:r.makeAnimationFrames(function(a){t.push(a)},e),delay:b.makeDelay(g),debounce:w.makeDebounce(g),periodic:h.makePeriodic(g),throttle:k.makeThrottle(g),
+b.peek().time;c<a;){c=b.shiftNextEntry();if(!c.cancelled)if(c.f&&c.f(c,a,b.add,d),"next"===c.type)c.stream.shamefullySendNext(c.value);else if("complete"===c.type)c.stream.shamefullySendComplete();else if("error"===c.type)c.stream.shamefullySendError(c.error);else throw Error("Unhandled event type: "+c.type);c=b.peek()&&b.peek().time||Infinity}}},10);return{pause:function(){return f=!0},resume:function(a){e(a);f=!1}}}Object.defineProperty(f,"__esModule",{value:!0});var d=e("./scheduler"),b=e("./delay"),
+w=e("./debounce"),h=e("./periodic"),k=e("./throttle"),r=e("./animation-frames"),c=e("./throttle-animation"),p=e("./run-virtually"),t=e("raf"),z=e("performance-now");f.timeDriver=function(a){function e(){return v}function f(a){v=a}function g(){return{schedule:z.add,currentTime:e}}var v=0,t=[],z=d.makeScheduler(),x=m(z,t,e,f);a=x.pause;var x=x.resume,B={animationFrames:r.makeAnimationFrames(function(a){t.push(a)},e),delay:b.makeDelay(g),debounce:w.makeDebounce(g),periodic:h.makePeriodic(g),throttle:k.makeThrottle(g),
 throttleAnimation:c.makeThrottleAnimation(function(){return B},z.add,e),_time:e,_scheduler:z.add,_pause:a,_resume:x,_runVirtually:function(a,b){p.runVirtually(z,a,e,f,b)},dispose:a,createOperator:g};return B}},{"./animation-frames":7,"./debounce":9,"./delay":10,"./periodic":13,"./run-virtually":15,"./scheduler":16,"./throttle":18,"./throttle-animation":17,"performance-now":38,raf:39}],20:[function(e,g,f){Object.defineProperty(f,"__esModule",{value:!0});var a=function(a){return a};f.setAdapt=function(e){a=
@@ -82,4 +82,4 @@ e};f.adapt=function(e){return a(e)}},{}],21:[function(e,g,f){g.exports=function(){return/[\u001b\u009b][[()#;?]*(?:[0-9]{1,4}(?:;[0-9]{0,4})*)?[0-9A-PRZcf-nqry=><]/g}},{}],22:[function(e,g,f){Object.defineProperty(g,"exports",{enumerable:!0,get:function(){var a={modifiers:{reset:[0,0],bold:[1,22],dim:[2,22],italic:[3,23],underline:[4,24],inverse:[7,27],hidden:[8,28],strikethrough:[9,29]},colors:{black:[30,39],red:[31,39],green:[32,39],yellow:[33,39],blue:[34,39],magenta:[35,39],cyan:[36,39],white:[37,
 q?a.value():a;b=y?b.value():b;e||(e=new n);b=A(a,b,c,d,e);break a}if(k){e||(e=new n);b:{var q=d&2,y=ga(a),f=y.length,k=ga(b).length;if(f==k||q){for(g=f;g--;){var P=y[g];if(!(q?P in b:v(b,P))){b=!1;break b}}if(k=e.get(a))b=k==b;else{k=!0;e.set(a,b);for(var p=q;++g<f;){P=y[g];var l=a[P],O=b[P];c&&(m=q?c(O,l,P,b,a,e):c(l,O,P,a,b,e));if(void 0===m?l!==O&&!A(l,O,c,d,e):!m){k=!1;break}p||(p="constructor"==P)}k&&!p&&(c=a.constructor,d=b.constructor,c!=d&&"constructor"in a&&"constructor"in b&&!("function"==
-typeof c&&c instanceof c&&"function"==typeof d&&d instanceof d)&&(k=!1));e["delete"](a);b=k}}else b=!1}}else b=!1}}return b}function G(a,b,c,d){var e,y=c.length,q=y,f=!d;if(null==a)return!q;for(a=Object(a);y--;){var h=c[y];if(f&&h[2]?h[1]!==a[h[0]]:!(h[0]in a))return!1}for(;++y<q;){h=c[y];var u=h[0],k=a[u],g=h[1];if(f&&h[2]){if(void 0===k&&!(u in a))return!1}else if(h=new n,d&&(e=d(k,g,u,a,b,h)),void 0===e?!A(g,k,d,3,h):!e)return!1}return!0}function x(a){var b=O(a);return 1==b.length&&b[0][2]?ja(b[0][0],
-b[0][1]):function(c){return c===a||G(c,a,b)}}function I(a,b){return Z(a)&&b===b&&!W(b)?ja(aa(a),b):function(c){var d=null==c?void 0:C(c,a);d=void 0===d?void 0:d;if(void 0===d&&d===b){if(d=null!=c){d=a;d=Z(d,c)?[d]:H(d);for(var e,y=-1,q=d.length;++y<q;){var f=aa(d[y]);if(!(e=null!=c&&f in Object(c)))break;c=c[f]}e?d=e:(q=c?c.length:0,d=!!q&&ba(q)&&ia(f,q)&&(Q(c)||la(c)||fa(c)))}f=d}else f=A(b,d,void 0,3);return f}}function J(a){return function(b){return null==b?void 0:b[a]}}function F(a){return function(b){return C(b,
+typeof c&&c instanceof c&&"function"==typeof d&&d instanceof d)&&(k=!1));e["delete"](a);b=k}}else b=!1}}else b=!1}}return b}function G(a,b,c,d){var e,y=c.length,f=y,q=!d;if(null==a)return!f;for(a=Object(a);y--;){var h=c[y];if(q&&h[2]?h[1]!==a[h[0]]:!(h[0]in a))return!1}for(;++y<f;){h=c[y];var u=h[0],k=a[u],g=h[1];if(q&&h[2]){if(void 0===k&&!(u in a))return!1}else if(h=new n,d&&(e=d(k,g,u,a,b,h)),void 0===e?!A(g,k,d,3,h):!e)return!1}return!0}function x(a){var b=O(a);return 1==b.length&&b[0][2]?ja(b[0][0],
+b[0][1]):function(c){return c===a||G(c,a,b)}}function I(a,b){return Z(a)&&b===b&&!W(b)?ja(aa(a),b):function(c){var d=null==c?void 0:C(c,a);d=void 0===d?void 0:d;if(void 0===d&&d===b){if(d=null!=c){d=a;d=Z(d,c)?[d]:H(d);for(var e,y=-1,f=d.length;++y<f;){var q=aa(d[y]);if(!(e=null!=c&&q in Object(c)))break;c=c[q]}e?d=e:(f=c?c.length:0,d=!!f&&ba(f)&&ia(q,f)&&(Q(c)||la(c)||fa(c)))}q=d}else q=A(b,d,void 0,3);return q}}function J(a){return function(b){return null==b?void 0:b[a]}}function F(a){return function(b){return C(b,
 a)}}function H(a){return Q(a)?a:ra(a)}function u(a,b,c,e,f,q){var y,h=f&2,u=a.length,k=b.length;if(u!=k&&!(h&&k>u))return!1;if(k=q.get(a))return k==b;var k=-1,g=!0,m=f&1?new B:void 0;for(q.set(a,b);++k<u;){var n=a[k],l=b[k];e&&(y=h?e(l,n,k,b,a,q):e(n,l,k,a,b,q));if(void 0!==y){if(y)continue;g=!1;break}if(m){if(!d(b,function(a,b){if(!m.has(b)&&(n===a||c(n,a,e,f,q)))return m.add(b)})){g=!1;break}}else if(n!==l&&!c(n,l,e,f,q)){g=!1;break}}q["delete"](a);return g}function L(a,b,c,d,e,q,f){switch(c){case "[object DataView]":if(a.byteLength!=
@@ -86,0 +86,0 @@ b.byteLength||a.byteOffset!=b.byteOffset)break;a=a.buffer;b=b.buffer;case "[object ArrayBuffer]":if(a.byteLength!=b.byteLength||!d(new ma(a),new ma(b)))break;return!0;case "[object Boolean]":case "[object Date]":return+a==+b;case "[object Error]":return a.name==b.name&&a.message==b.message;case "[object Number]":return a!=+a?b!=+b:a==+b;case "[object RegExp]":case "[object String]":return a==b+"";case "[object Map]":var y=k;case "[object Set]":y||(y=r);if(a.size!=b.size&&!(q&2))break;if(c=f.get(a))return c==

lib/cjs/src/throttle.js

@@ -22,3 +22,3 @@ "use strict";
         complete: function () {
-            listener.complete();
+            schedule.complete(listener, currentTime());
         },
@@ -25,0 +25,0 @@ };

lib/cjs/src/time-driver.js

@@ -57,9 +57,11 @@ "use strict";
                 }
-                if (eventToProcess.type === 'complete') {
+                else if (eventToProcess.type === 'complete') {
                     eventToProcess.stream.shamefullySendComplete();
                 }
-                if (eventToProcess.type === 'error') {
+                else if (eventToProcess.type === 'error') {
                     eventToProcess.stream.shamefullySendError(eventToProcess.error);
                 }
-                throw new Error('Unhandled event type: ' + eventToProcess.type);
+                else {
+                    throw new Error('Unhandled event type: ' + eventToProcess.type);
+                }
             }
@@ -66,0 +68,0 @@ nextEventTime = (scheduler.peek() && scheduler.peek().time) || Infinity;

lib/es6/src/throttle.js

@@ -20,3 +20,3 @@ import xs from 'xstream';
         complete: function () {
-            listener.complete();
+            schedule.complete(listener, currentTime());
         },
@@ -23,0 +23,0 @@ };

lib/es6/src/time-driver.js

@@ -55,9 +55,11 @@ import { makeScheduler } from './scheduler';
                 }
-                if (eventToProcess.type === 'complete') {
+                else if (eventToProcess.type === 'complete') {
                     eventToProcess.stream.shamefullySendComplete();
                 }
-                if (eventToProcess.type === 'error') {
+                else if (eventToProcess.type === 'error') {
                     eventToProcess.stream.shamefullySendError(eventToProcess.error);
                 }
-                throw new Error('Unhandled event type: ' + eventToProcess.type);
+                else {
+                    throw new Error('Unhandled event type: ' + eventToProcess.type);
+                }
             }
@@ -64,0 +66,0 @@ nextEventTime = (scheduler.peek() && scheduler.peek().time) || Infinity;

most.d.ts

 import { Stream } from 'most';
-import { Frame } from './src/animation-frames';
-import { Comparator, OperatorArgs } from './src/types';
+import { Frame } from './lib/cjs/src/animation-frames';
+import { Comparator, OperatorArgs } from './lib/cjs/src/types';
 declare type Operator = <T>(stream: Stream<T>) => Stream<T>;
@@ -12,2 +12,3 @@ interface TimeSource {
     throttleAnimation: Operator;
+    dispose(): void;
 }
@@ -14,0 +15,0 @@ interface MockTimeSource extends TimeSource {

most.js

 "use strict";
-Object.defineProperty(exports, "__esModule", { value: true });
+exports.__esModule = true;
 var most = require("most");
 var adapt_1 = require("@cycle/run/lib/adapt");
-var mock_time_source_1 = require("./src/mock-time-source");
-var time_driver_1 = require("./src/time-driver");
+var mock_time_source_1 = require("./lib/cjs/src/mock-time-source");
+var time_driver_1 = require("./lib/cjs/src/time-driver");
 adapt_1.setAdapt(function (stream) { return most.from(stream); });
@@ -16,2 +16,1 @@ function mockTimeSource(args) {
 exports.timeDriver = timeDriver;
-//# sourceMappingURL=most.js.map

package.json

 {
   "name": "@cycle/time",
-  "version": "0.12.0",
+  "version": "0.13.0",
   "description": "A time driver designed to enable awesome testing and dev tooling",
@@ -62,4 +62,5 @@ "license": "MIT",
     "browserify": "../node_modules/.bin/browserify lib/cjs/index.js --global-transform=browserify-shim --standalone CycleTime --exclude xstream --outfile dist/cycle-time.js",
-    "minify": "node ../.scripts/minify.js dist/cycle-time.js dist/cycle-time.min.js"
+    "minify": "node ../.scripts/minify.js dist/cycle-time.js dist/cycle-time.min.js",
+    "postlib": "tsc rxjs.ts most.ts --declaration --lib DOM,ES5,ES6"
   }
 }

rxjs.d.ts

 import { Observable } from 'rxjs/Observable';
 import 'rxjs/add/observable/from';
-import { Frame } from './src/animation-frames';
-import { Comparator, OperatorArgs } from './src/types';
+import { Frame } from './lib/cjs/src/animation-frames';
+import { Comparator, OperatorArgs } from './lib/cjs/src/types';
 declare type Operator = <T>(observable: Observable<T>) => Observable<T>;
@@ -14,2 +14,3 @@ interface TimeSource {
     throttleAnimation: Operator;
+    dispose(): void;
 }
@@ -16,0 +17,0 @@ interface MockTimeSource extends TimeSource {

rxjs.js

 "use strict";
-Object.defineProperty(exports, "__esModule", { value: true });
+exports.__esModule = true;
 var Observable_1 = require("rxjs/Observable");
@@ -7,4 +7,4 @@ // tslint:disable-next-line:no-import-side-effect
 var adapt_1 = require("@cycle/run/lib/adapt");
-var mock_time_source_1 = require("./src/mock-time-source");
-var time_driver_1 = require("./src/time-driver");
+var mock_time_source_1 = require("./lib/cjs/src/mock-time-source");
+var time_driver_1 = require("./lib/cjs/src/time-driver");
 adapt_1.setAdapt(function (stream) { return Observable_1.Observable.from(stream); });
@@ -19,2 +19,1 @@ function mockTimeSource(args) {
 exports.timeDriver = timeDriver;
-//# sourceMappingURL=rxjs.js.map

No alert changes

Worsened metrics

Total package byte prevSize

436809

decreased by-1.73%

Number of package files

106

decreased by-10.17%

Lines of code

9135

decreased by-1.54%

No dependency changes