diff options
Diffstat (limited to 'sandbox/testAppNevena/Front/node_modules/rxjs/_esm5/internal/innerSubscribe.js')
-rw-r--r-- | sandbox/testAppNevena/Front/node_modules/rxjs/_esm5/internal/innerSubscribe.js | 100 |
1 files changed, 0 insertions, 100 deletions
diff --git a/sandbox/testAppNevena/Front/node_modules/rxjs/_esm5/internal/innerSubscribe.js b/sandbox/testAppNevena/Front/node_modules/rxjs/_esm5/internal/innerSubscribe.js deleted file mode 100644 index 0c13dfd7..00000000 --- a/sandbox/testAppNevena/Front/node_modules/rxjs/_esm5/internal/innerSubscribe.js +++ /dev/null @@ -1,100 +0,0 @@ -/** PURE_IMPORTS_START tslib,_Subscriber,_Observable,_util_subscribeTo PURE_IMPORTS_END */ -import * as tslib_1 from "tslib"; -import { Subscriber } from './Subscriber'; -import { Observable } from './Observable'; -import { subscribeTo } from './util/subscribeTo'; -var SimpleInnerSubscriber = /*@__PURE__*/ (function (_super) { - tslib_1.__extends(SimpleInnerSubscriber, _super); - function SimpleInnerSubscriber(parent) { - var _this = _super.call(this) || this; - _this.parent = parent; - return _this; - } - SimpleInnerSubscriber.prototype._next = function (value) { - this.parent.notifyNext(value); - }; - SimpleInnerSubscriber.prototype._error = function (error) { - this.parent.notifyError(error); - this.unsubscribe(); - }; - SimpleInnerSubscriber.prototype._complete = function () { - this.parent.notifyComplete(); - this.unsubscribe(); - }; - return SimpleInnerSubscriber; -}(Subscriber)); -export { SimpleInnerSubscriber }; -var ComplexInnerSubscriber = /*@__PURE__*/ (function (_super) { - tslib_1.__extends(ComplexInnerSubscriber, _super); - function ComplexInnerSubscriber(parent, outerValue, outerIndex) { - var _this = _super.call(this) || this; - _this.parent = parent; - _this.outerValue = outerValue; - _this.outerIndex = outerIndex; - return _this; - } - ComplexInnerSubscriber.prototype._next = function (value) { - this.parent.notifyNext(this.outerValue, value, this.outerIndex, this); - }; - ComplexInnerSubscriber.prototype._error = function (error) { - this.parent.notifyError(error); - this.unsubscribe(); - }; - ComplexInnerSubscriber.prototype._complete = function () { - this.parent.notifyComplete(this); - this.unsubscribe(); - }; - return ComplexInnerSubscriber; -}(Subscriber)); -export { ComplexInnerSubscriber }; -var SimpleOuterSubscriber = /*@__PURE__*/ (function (_super) { - tslib_1.__extends(SimpleOuterSubscriber, _super); - function SimpleOuterSubscriber() { - return _super !== null && _super.apply(this, arguments) || this; - } - SimpleOuterSubscriber.prototype.notifyNext = function (innerValue) { - this.destination.next(innerValue); - }; - SimpleOuterSubscriber.prototype.notifyError = function (err) { - this.destination.error(err); - }; - SimpleOuterSubscriber.prototype.notifyComplete = function () { - this.destination.complete(); - }; - return SimpleOuterSubscriber; -}(Subscriber)); -export { SimpleOuterSubscriber }; -var ComplexOuterSubscriber = /*@__PURE__*/ (function (_super) { - tslib_1.__extends(ComplexOuterSubscriber, _super); - function ComplexOuterSubscriber() { - return _super !== null && _super.apply(this, arguments) || this; - } - ComplexOuterSubscriber.prototype.notifyNext = function (_outerValue, innerValue, _outerIndex, _innerSub) { - this.destination.next(innerValue); - }; - ComplexOuterSubscriber.prototype.notifyError = function (error) { - this.destination.error(error); - }; - ComplexOuterSubscriber.prototype.notifyComplete = function (_innerSub) { - this.destination.complete(); - }; - return ComplexOuterSubscriber; -}(Subscriber)); -export { ComplexOuterSubscriber }; -export function innerSubscribe(result, innerSubscriber) { - if (innerSubscriber.closed) { - return undefined; - } - if (result instanceof Observable) { - return result.subscribe(innerSubscriber); - } - var subscription; - try { - subscription = subscribeTo(result)(innerSubscriber); - } - catch (error) { - innerSubscriber.error(error); - } - return subscription; -} -//# sourceMappingURL=innerSubscribe.js.map |