-/** PURE_IMPORTS_START tslib,_Subject,_OuterSubscriber,_util_subscribeToResult PURE_IMPORTS_END */
+/** PURE_IMPORTS_START tslib,_Subject,_innerSubscribe PURE_IMPORTS_END */
import * as tslib_1 from "tslib";
import { Subject } from '../Subject';
-import { OuterSubscriber } from '../OuterSubscriber';
-import { subscribeToResult } from '../util/subscribeToResult';
+import { SimpleOuterSubscriber, innerSubscribe, SimpleInnerSubscriber } from '../innerSubscribe';
export function retryWhen(notifier) {
return function (source) { return source.lift(new RetryWhenOperator(notifier, source)); };
}
catch (e) {
return _super.prototype.error.call(this, e);
}
- retriesSubscription = subscribeToResult(this, retries);
+ retriesSubscription = innerSubscribe(retries, new SimpleInnerSubscriber(this));
}
else {
- this.errors = null;
- this.retriesSubscription = null;
+ this.errors = undefined;
+ this.retriesSubscription = undefined;
}
this._unsubscribeAndRecycle();
this.errors = errors;
var _a = this, errors = _a.errors, retriesSubscription = _a.retriesSubscription;
if (errors) {
errors.unsubscribe();
- this.errors = null;
+ this.errors = undefined;
}
if (retriesSubscription) {
retriesSubscription.unsubscribe();
- this.retriesSubscription = null;
+ this.retriesSubscription = undefined;
}
- this.retries = null;
+ this.retries = undefined;
};
- RetryWhenSubscriber.prototype.notifyNext = function (outerValue, innerValue, outerIndex, innerIndex, innerSub) {
+ RetryWhenSubscriber.prototype.notifyNext = function () {
var _unsubscribe = this._unsubscribe;
this._unsubscribe = null;
this._unsubscribeAndRecycle();
this.source.subscribe(this);
};
return RetryWhenSubscriber;
-}(OuterSubscriber));
+}(SimpleOuterSubscriber));
//# sourceMappingURL=retryWhen.js.map