zen-observable-ts - npm Package Compare versions

Comparing version 0.1.0 to 0.2.0

dist/tests/filter.js

@@ -27,3 +27,5 @@ "use strict";
             return zenObservable_1.default.from([1, 2, 3, 4])
-                .filter(function () { throw error; })
+                .filter(function () {
+                throw error;
+            })
                 .subscribe({
@@ -30,0 +32,0 @@ error: function (err) {

dist/tests/flatMap.js

@@ -39,3 +39,5 @@ "use strict";
             return zenObservable_1.default.from([1, 2, 3, 4])
-                .flatMap(function () { throw error; })
+                .flatMap(function () {
+                throw error;
+            })
                 .subscribe({
@@ -42,0 +44,0 @@ error: function (err) {

dist/tests/forEach.js

@@ -18,5 +18,6 @@ "use strict";
         })
-            .forEach(function (x) { return x; }).catch(function (err) { return assert.deepEqual(err, error); });
+            .forEach(function (x) { return x; })
+            .catch(function (err) { return assert.deepEqual(err, error); });
     });
 });
 //# sourceMappingURL=forEach.js.map

dist/tests/map.js

@@ -23,3 +23,5 @@ "use strict";
             return zenObservable_1.default.from([1, 2, 3, 4])
-                .map(function () { throw error; })
+                .map(function () {
+                throw error;
+            })
                 .subscribe({
@@ -26,0 +28,0 @@ error: function (err) {

dist/tests/observer.js

@@ -59,9 +59,11 @@ "use strict";
         var error = new Error('completed');
-        return (new Promise(function (resolve, reject) { return new zenObservable_1.default(function (observer) {
-            observer.complete();
-        }).subscribe({
-            complete: function () {
-                reject(error);
-            },
-        }); }).catch(function (err) { return chai_1.assert.deepEqual(err, error); }));
+        return new Promise(function (resolve, reject) {
+            return new zenObservable_1.default(function (observer) {
+                observer.complete();
+            }).subscribe({
+                complete: function () {
+                    reject(error);
+                },
+            });
+        }).catch(function (err) { return chai_1.assert.deepEqual(err, error); });
     });
@@ -68,0 +70,0 @@ it('calling without options does not throw', function () {

dist/tests/reduce.js

@@ -62,3 +62,5 @@ "use strict";
             return zenObservable_1.default.from([1, 2, 3, 4])
-                .reduce(function () { throw error; })
+                .reduce(function () {
+                throw error;
+            })
                 .subscribe({
@@ -65,0 +67,0 @@ error: function (err) {

package.json

 {
   "name": "zen-observable-ts",
-  "version": "0.1.0",
+  "version": "0.2.0",
   "description": "An Implementation of ES Observables in Typescript",
@@ -28,5 +28,5 @@ "author": "Evans Hauser <[e-mail]>",
     "prebuild": "npm run clean:dist",
-    "build": "tsc",
+    "build": "tsc -p .",
     "postbuild": "cp -R ./dist/src/. ./lib",
-    "watch": "tsc -w",
+    "watch": "tsc -w -p .",
     "clean": "npm run clean:dist && npm run clean:coverage",
@@ -41,3 +41,2 @@ "clean:dist": "rimraf dist/* && rimraf lib/*",
     "@types/mocha": "^2.2.31",
-    "@types/zen-observable": "^0.5.1",
     "chai": "^4.0.2",
@@ -44,0 +43,0 @@ "chai-as-promised": "^7.1.1",

src/zenObservable.ts

@@ -5,7 +5,5 @@ import { ZenObservable } from './types';
 
-declare global {
-  interface SymbolConstructor {
-    observable: symbol;
-  }
-}
+export type Observer<T> = ZenObservable.Observer<T>;
+export type Subscriber<T> = ZenObservable.Subscriber<T>;
+export type ObservableLike<T> = ZenObservable.ObservableLike<T>;
 
@@ -49,3 +47,3 @@ // === Abstract Operations ===
 
-class Subscription implements ZenObservable.Subscription {
+export class Subscription implements ZenObservable.Subscription {
   public _observer?: ZenObservable.Observer<any>;
@@ -120,3 +118,4 @@ public _cleanup: () => void;
 
-class SubscriptionObserver<T> implements ZenObservable.SubscriptionObserver<T> {
+export class SubscriptionObserver<T>
+  implements ZenObservable.SubscriptionObserver<T> {
   private _subscription: Subscription;
@@ -512,6 +511,2 @@
   }
-  // [Symbol.species](){
-  //   return <Observable<T>>this;
-  //   //configurable: true,
-  // }
 }

New alerts

License Policy Violation

License

This package is not allowed per your license policy. Review the package's license to ensure compliance.

Found 1 instance in 1 package

Fixed alerts

License Policy Violation

License

This package is not allowed per your license policy. Review the package's license to ensure compliance.

Found 1 instance in 1 package

Improved metrics

Total package byte prevSize

231731

increased by0.06%

Dev dependency count

13

decreased by-7.14%

Lines of code

2791

increased by0.22%

No dependency changes