fix: catch within innerSubscribe

Closes #5344
ReactiveX · Mar 28, 2021 · eea6559 · eea6559
1 parent 50c99a3
commit eea6559
Showing 1 changed file with 7 additions and 1 deletion.
diff --git a/src/internal/innerSubscribe.ts b/src/internal/innerSubscribe.ts
@@ -110,5 +110,11 @@ export function innerSubscribe(result: any, innerSubscriber: Subscriber<any>): S
   if (result instanceof Observable) {
     return result.subscribe(innerSubscriber);
   }
-  return subscribeTo(result)(innerSubscriber) as Subscription;
+  let subscription: Subscription;
+  try {
+    subscription = subscribeTo(result)(innerSubscriber) as Subscription;
+  } catch (error) {
+    innerSubscriber.error(error);
+  }
+  return subscription;
 }