-import { OuterSubscriber } from '../OuterSubscriber';
-import { InnerSubscriber } from '../InnerSubscriber';
-import { subscribeToResult } from '../util/subscribeToResult';
+import { SimpleOuterSubscriber, SimpleInnerSubscriber, innerSubscribe } from '../innerSubscribe';
export function catchError(selector) {
return function catchErrorOperatorFunction(source) {
const operator = new CatchOperator(selector);
return source.subscribe(new CatchSubscriber(subscriber, this.selector, this.caught));
}
}
-class CatchSubscriber extends OuterSubscriber {
+class CatchSubscriber extends SimpleOuterSubscriber {
constructor(destination, selector, caught) {
super(destination);
this.selector = selector;
return;
}
this._unsubscribeAndRecycle();
- const innerSubscriber = new InnerSubscriber(this, undefined, undefined);
+ const innerSubscriber = new SimpleInnerSubscriber(this);
this.add(innerSubscriber);
- const innerSubscription = subscribeToResult(this, result, undefined, undefined, innerSubscriber);
+ const innerSubscription = innerSubscribe(result, innerSubscriber);
if (innerSubscription !== innerSubscriber) {
this.add(innerSubscription);
}