immview - npm Package Compare versions

Comparing version 3.2.3 to 3.2.4

changelog.md

 # Changelog
 
+## 3.2.4
+
+- fix: memory issues with typescript 2.4+
+
 ## 3.2.3
@@ -4,0 +8,0 @@ - fix: `distinct` operator should not trigger predicate for first value.

dist/Atom.js

@@ -17,3 +17,3 @@ "use strict";
 var AtomSymbol = typeof Symbol !== 'undefined' ? Symbol('AtomSymbol') : 'AtomSymbol';
-var Atom = (function (_super) {
+var Atom = /** @class */ (function (_super) {
     __extends(Atom, _super);
@@ -20,0 +20,0 @@ function Atom() {

dist/Base.js

@@ -6,3 +6,5 @@ "use strict";
 function fillAsyncIterSymbol() {
-    Symbol.asyncIterator = Symbol.asyncIterator || Symbol('Symbol.asyncIterator');
+    ;
+    Symbol.asyncIterator =
+        Symbol.asyncIterator || Symbol('Symbol.asyncIterator');
 }
@@ -13,3 +15,3 @@ fillAsyncIterSymbol();
 var hasRefF = function () { return false; };
-var Base = (function () {
+var Base = /** @class */ (function () {
     function Base(dispatch) {
@@ -42,6 +44,3 @@ this.dispatch = dispatch;
             return;
-        this.awaitingMessages.push([
-            Types_1.MessageTypes.Next,
-            nextValue,
-        ]);
+        this.awaitingMessages.push([Types_1.MessageTypes.Next, nextValue]);
         this.dispatch(this.flush);
@@ -52,6 +51,3 @@ };
             return;
-        this.awaitingMessages.push([
-            Types_1.MessageTypes.Error,
-            reason,
-        ]);
+        this.awaitingMessages.push([Types_1.MessageTypes.Error, reason]);
         this.dispatch(this.flush);
@@ -62,6 +58,3 @@ };
             return;
-        this.awaitingMessages.push([
-            Types_1.MessageTypes.Complete,
-            undefined,
-        ]);
+        this.awaitingMessages.push([Types_1.MessageTypes.Complete, undefined]);
         this.dispatch(this.flush);
@@ -85,3 +78,5 @@ };
             },
-            get closed() { return __this.observers.indexOf(observer) === -1; }
+            get closed() {
+                return __this.observers.indexOf(observer) === -1;
+            }
         };
@@ -94,3 +89,4 @@ };
                 if (typeof next === 'function') {
-                    var endMeasurement = Diagnose_1.diagnose.isOn && Diagnose_1.diagnose.measure(this.name + " next(" + (next.name || '') + ")");
+                    var endMeasurement = Diagnose_1.diagnose.isOn &&
+                        Diagnose_1.diagnose.measure(this.name + " next(" + (next.name || '') + ")");
                     var nextVal = next(this.deref());
@@ -142,3 +138,5 @@ if (endMeasurement)
             next: function () {
-                var passer = new Promise(function (resolve) { consumers.push(resolve); });
+                var passer = new Promise(function (resolve) {
+                    consumers.push(resolve);
+                });
                 while (products.length && consumers.length) {
@@ -164,9 +162,9 @@ consumers.shift()(products.shift());
             _this.subscribe({
-                start: function (_sub) { sub = _sub; },
+                start: function (_sub) {
+                    sub = _sub;
+                },
                 next: function (value) {
                     sub.unsubscribe();
                     try {
-                        resolve(onsuccess
-                            ? onsuccess(value)
-                            : value);
+                        resolve(onsuccess ? onsuccess(value) : value);
                     }
@@ -201,3 +199,3 @@ catch (e) {
             error: error || noop,
-            complete: complete || noop,
+            complete: complete || noop
         };
@@ -204,0 +202,0 @@ }

dist/BaseAtom.js

@@ -17,3 +17,3 @@ "use strict";
 var dispatchAtom = function (job) { return DispatcherInstance_1.dispatch(job, DispatcherPriorities_1.DispatcherPriorities.ATOM); };
-var BaseAtom = (function (_super) {
+var BaseAtom = /** @class */ (function (_super) {
     __extends(BaseAtom, _super);
@@ -20,0 +20,0 @@ function BaseAtom(initialValue) {

dist/BaseObservable.d.ts

@@ -1,2 +0,2 @@
-import { Subscriber, Subscription, Observer, ValueListener, ErrorListener, CompletionListener, NO_VALUE_T } from './Types';
+import { Subscriber, Subscription, Observer, ValueListener, ErrorListener, CompletionListener, NoValue } from './Types';
 import { Base } from './Base';
@@ -6,3 +6,3 @@ export declare class BaseObservable<T> extends Base<T> {
     constructor(subscriber?: Subscriber<T>);
-    previous(): T | NO_VALUE_T;
+    previous(): T | NoValue;
     complete(): void;
@@ -9,0 +9,0 @@ protected flush: () => void;

dist/BaseObservable.js

@@ -19,3 +19,3 @@ "use strict";
 var dispatchObservable = function (job) { return DispatcherInstance_1.dispatch(job, DispatcherPriorities_1.DispatcherPriorities.OBSERVABLE); };
-var BaseObservable = (function (_super) {
+var BaseObservable = /** @class */ (function (_super) {
     __extends(BaseObservable, _super);
@@ -36,3 +36,5 @@ function BaseObservable(subscriber) {
         };
-        if (subscriber && typeof subscriber.name === 'string' && subscriber.name.length > 0) {
+        if (subscriber &&
+            typeof subscriber.name === 'string' &&
+            subscriber.name.length > 0) {
             _this.name = subscriber.name + "$";
@@ -42,12 +44,12 @@ }
             var node_1 = _this;
-            _this.cancelSubscriber = (subscriber({
-                start: node_1.start.bind(node_1),
-                next: node_1.next.bind(node_1),
-                error: node_1.error.bind(node_1),
-                complete: node_1.complete.bind(node_1),
-                get closed() {
-                    return node_1.observers.length > 0;
-                }
-            }) ||
-                noop);
+            _this.cancelSubscriber =
+                subscriber({
+                    start: node_1.start.bind(node_1),
+                    next: node_1.next.bind(node_1),
+                    error: node_1.error.bind(node_1),
+                    complete: node_1.complete.bind(node_1),
+                    get closed() {
+                        return node_1.observers.length > 0;
+                    }
+                }) || noop;
         }
@@ -54,0 +56,0 @@ return _this;

dist/Combine.js

@@ -22,3 +22,3 @@ "use strict";
 var Atom_1 = require("./Atom");
-var Combine = (function (_super) {
+var Combine = /** @class */ (function (_super) {
     __extends(Combine, _super);
@@ -25,0 +25,0 @@ function Combine(sources) {

dist/Diagnose.js

@@ -11,3 +11,3 @@ "use strict";
 Object.defineProperty(exports, "__esModule", { value: true });
-var Diagnose = (function () {
+var Diagnose = /** @class */ (function () {
     function Diagnose() {
@@ -14,0 +14,0 @@ this.list = null;

dist/Dispatcher.js

 "use strict";
 Object.defineProperty(exports, "__esModule", { value: true });
-var Dispatcher = (function () {
+var Dispatcher = /** @class */ (function () {
     function Dispatcher() {
@@ -5,0 +5,0 @@ var _this = this;

dist/Domain.action.spec.js

@@ -27,3 +27,3 @@ "use strict";
     it('extending class method can be decorated to become an action', function (done) {
-        var DerivativeOfDomain = (function (_super) {
+        var DerivativeOfDomain = /** @class */ (function (_super) {
             __extends(DerivativeOfDomain, _super);
@@ -54,3 +54,3 @@ function DerivativeOfDomain() {
     it('decorated class method returns promise of execution', function (done) {
-        var DerivativeOfDomain = (function (_super) {
+        var DerivativeOfDomain = /** @class */ (function (_super) {
             __extends(DerivativeOfDomain, _super);
@@ -57,0 +57,0 @@ function DerivativeOfDomain() {

dist/Domain.js

@@ -10,3 +10,3 @@ "use strict";
 fillAsyncIterSymbol();
-var Domain = (function () {
+var Domain = /** @class */ (function () {
     function Domain($) {
@@ -13,0 +13,0 @@ this.$ = $;

dist/Observable.js

@@ -17,3 +17,3 @@ "use strict";
 var ObservableSymbol = typeof Symbol !== 'undefined' ? Symbol('ObservableSymbol') : 'ObservableSymbol';
-var Observable = (function (_super) {
+var Observable = /** @class */ (function (_super) {
     __extends(Observable, _super);
@@ -20,0 +20,0 @@ function Observable() {

dist/Process.js

@@ -39,3 +39,3 @@ "use strict";
 var Observable_1 = require("./Observable");
-var Process = (function () {
+var Process = /** @class */ (function () {
     function Process(task) {
@@ -42,0 +42,0 @@ var _this = this;

dist/Types.d.ts

@@ -7,3 +7,5 @@ import { Atom } from './Atom';
 }
-export declare type Transformer<T> = (currentValue: T) => T;
+export interface Transformer<T> {
+    (currentValue: T): T;
+}
 export declare type NextStep<T> = T | Transformer<T>;
@@ -13,3 +15,3 @@ export interface Closeable {
 }
-export declare type Observer<T> = {
+export interface Observer<T> {
     start: (subscription: Subscription) => void;
@@ -19,4 +21,4 @@ next: (candidate: T) => void;
     complete: () => void;
-};
-export declare type StreamObserver<T> = {
+}
+export interface StreamObserver<T> {
     start: (subscription: Subscription) => void;
@@ -26,3 +28,3 @@ next: (candidate: NextStep<T>) => void;
     complete: () => void;
-};
+}
 export interface ValueListener<T> {
@@ -37,3 +39,4 @@ (nextValue: T): any;
 }
-export declare type SubscriptionObserver<T> = Observer<T> & Closeable;
+export interface SubscriptionObserver<T> extends Observer<T>, Closeable {
+}
 export interface Subscriber<T> {
@@ -55,4 +58,5 @@ (observer: SubscriptionObserver<T>): void | (() => void);
 }
-export declare type Stream<T> = StreamObserver<T> & Closeable & Subscribable<T> & Named & Receiver<T> & AsyncIterable<T> & PromiseLike<T>;
-export declare type OpStream<T> = Stream<T> & {
+export interface Stream<T> extends StreamObserver<T>, Closeable, Subscribable<T>, Named, Receiver<T>, AsyncIterable<T>, PromiseLike<T> {
+}
+export interface OpStream<T> extends Stream<T> {
     toPromise(): Promise<T>;
@@ -68,5 +72,6 @@ map<U>(action: (value: T) => U): OpStream<U>;
     vaporize(): Observable<T>;
-};
-export declare type NO_VALUE_T = {};
-export declare const NO_VALUE: NO_VALUE_T;
+}
+export interface NoValue {
+}
+export declare const NO_VALUE: NoValue;
 export declare type Message<T> = [MessageTypes, NextStep<T> | Error | void];
@@ -73,0 +78,0 @@ export declare enum MessageTypes {

package.json

 {
   "name": "immview",
-  "version": "3.2.3",
+  "version": "3.2.4",
   "description": "",
@@ -59,4 +59,4 @@ "main": "./dist/index.js",
   "dependencies": {
-    "typescript": "^2.4.0"
+    "typescript": "^2.5.2"
   }
 }

No alert changes

Worsened metrics

Total package byte prevSize

471404

decreased by-31.1%

Number of package files

87

decreased by-1.14%

Lines of code

3795

decreased by-63.86%

Dependency changes

• Updatedtypescript@^2.5.2