rxjs - npm Package Compare versions

Comparing version 6.6.6 to 6.6.7

_esm2015/internal/innerSubscribe.js

@@ -69,4 +69,11 @@ import { Subscriber } from './Subscriber';
     }
-    return subscribeTo(result)(innerSubscriber);
+    let subscription;
+    try {
+        subscription = subscribeTo(result)(innerSubscriber);
+    }
+    catch (error) {
+        innerSubscriber.error(error);
+    }
+    return subscription;
 }
 //# sourceMappingURL=innerSubscribe.js.map

_esm5/internal/innerSubscribe.js

@@ -91,4 +91,11 @@ /** PURE_IMPORTS_START tslib,_Subscriber,_Observable,_util_subscribeTo PURE_IMPORTS_END */
     }
-    return subscribeTo(result)(innerSubscriber);
+    var subscription;
+    try {
+        subscription = subscribeTo(result)(innerSubscriber);
+    }
+    catch (error) {
+        innerSubscriber.error(error);
+    }
+    return subscription;
 }
 //# sourceMappingURL=innerSubscribe.js.map

internal/innerSubscribe.js

@@ -104,5 +104,12 @@ "use strict";
     }
-    return subscribeTo_1.subscribeTo(result)(innerSubscriber);
+    var subscription;
+    try {
+        subscription = subscribeTo_1.subscribeTo(result)(innerSubscriber);
+    }
+    catch (error) {
+        innerSubscriber.error(error);
+    }
+    return subscription;
 }
 exports.innerSubscribe = innerSubscribe;
 //# sourceMappingURL=innerSubscribe.js.map

internal/symbol/observable.d.ts

@@ -1,8 +0,2 @@
-/** Symbol.observable addition */
-declare global {
-    interface SymbolConstructor {
-        readonly observable: symbol;
-    }
-}
 /** Symbol.observable or a string "@@observable". Used for interop */
 export declare const observable: string | symbol;

internal/types.d.ts

 import { Observable } from './Observable';
 import { Subscription } from './Subscription';
+/**
+ * Note: This will add Symbol.observable globally for all TypeScript users,
+ * however, we are no longer polyfilling Symbol.observable
+ */
+declare global {
+    interface SymbolConstructor {
+        readonly observable: symbol;
+    }
+}
 /** OPERATOR INTERFACES */
@@ -4,0 +13,0 @@ export interface UnaryFunction<T, R> {

package.json

 {
   "name": "rxjs",
-  "version": "6.6.6",
+  "version": "6.6.7",
   "description": "Reactive Extensions for modern JavaScript",
@@ -5,0 +5,0 @@ "main": "./index.js",

src/internal/innerSubscribe.ts

@@ -113,3 +113,9 @@ /** @prettier */
   }
-  return subscribeTo(result)(innerSubscriber) as Subscription;
+  let subscription: Subscription;
+  try {
+    subscription = subscribeTo(result)(innerSubscriber) as Subscription;
+  } catch (error) {
+    innerSubscriber.error(error);
+  }
+  return subscription;
 }

src/internal/symbol/observable.ts

@@ -1,11 +0,2 @@
-/** Symbol.observable addition */
-/* Note: This will add Symbol.observable globally for all TypeScript users,
-  however, we are no longer polyfilling Symbol.observable */
-declare global {
-  interface SymbolConstructor {
-    readonly observable: symbol;
-  }
-}
-
 /** Symbol.observable or a string "@@observable". Used for interop */
 export const observable = (() => typeof Symbol === 'function' && Symbol.observable || '@@observable')();

src/internal/types.ts

 import { Observable } from './Observable';
 import { Subscription } from './Subscription';
 
+/**
+ * Note: This will add Symbol.observable globally for all TypeScript users,
+ * however, we are no longer polyfilling Symbol.observable
+ */
+declare global {
+  interface SymbolConstructor {
+    readonly observable: symbol;
+  }
+}
+
 /** OPERATOR INTERFACES */
@@ -5,0 +15,0 @@

No alert changes

Improved metrics

Total package byte prevSize

5125315

increased by0.03%

Lines of code

71690

increased by0.03%

No dependency changes