{"ast":null,"code":"import _classCallCheck from \"C:/Users/lucas.hsilva/Desktop/Nome_do_projeto/thf2/node_modules/@babel/runtime/helpers/esm/classCallCheck.js\";\nimport _createClass from \"C:/Users/lucas.hsilva/Desktop/Nome_do_projeto/thf2/node_modules/@babel/runtime/helpers/esm/createClass.js\";\nimport _assertThisInitialized from \"C:/Users/lucas.hsilva/Desktop/Nome_do_projeto/thf2/node_modules/@babel/runtime/helpers/esm/assertThisInitialized.js\";\nimport _inherits from \"C:/Users/lucas.hsilva/Desktop/Nome_do_projeto/thf2/node_modules/@babel/runtime/helpers/esm/inherits.js\";\nimport _createSuper from \"C:/Users/lucas.hsilva/Desktop/Nome_do_projeto/thf2/node_modules/@babel/runtime/helpers/esm/createSuper.js\";\nimport _get from \"C:/Users/lucas.hsilva/Desktop/Nome_do_projeto/thf2/node_modules/@babel/runtime/helpers/esm/get.js\";\nimport _getPrototypeOf from \"C:/Users/lucas.hsilva/Desktop/Nome_do_projeto/thf2/node_modules/@babel/runtime/helpers/esm/getPrototypeOf.js\";\nimport { Subscriber } from '../Subscriber';\nexport function createOperatorSubscriber(destination, onNext, onComplete, onError, onFinalize) {\n  return new OperatorSubscriber(destination, onNext, onComplete, onError, onFinalize);\n}\nexport var OperatorSubscriber = /*#__PURE__*/function (_Subscriber) {\n  _inherits(OperatorSubscriber, _Subscriber);\n  var _super = _createSuper(OperatorSubscriber);\n  function OperatorSubscriber(destination, onNext, onComplete, onError, onFinalize, shouldUnsubscribe) {\n    var _thisSuper, _thisSuper2, _thisSuper3, _this;\n    _classCallCheck(this, OperatorSubscriber);\n    _this = _super.call(this, destination);\n    _this.onFinalize = onFinalize;\n    _this.shouldUnsubscribe = shouldUnsubscribe;\n    _this._next = onNext ? function (value) {\n      try {\n        onNext(value);\n      } catch (err) {\n        destination.error(err);\n      }\n    } : _get((_thisSuper = _assertThisInitialized(_this), _getPrototypeOf(OperatorSubscriber.prototype)), \"_next\", _thisSuper);\n    _this._error = onError ? function (err) {\n      try {\n        onError(err);\n      } catch (err) {\n        destination.error(err);\n      } finally {\n        this.unsubscribe();\n      }\n    } : _get((_thisSuper2 = _assertThisInitialized(_this), _getPrototypeOf(OperatorSubscriber.prototype)), \"_error\", _thisSuper2);\n    _this._complete = onComplete ? function () {\n      try {\n        onComplete();\n      } catch (err) {\n        destination.error(err);\n      } finally {\n        this.unsubscribe();\n      }\n    } : _get((_thisSuper3 = _assertThisInitialized(_this), _getPrototypeOf(OperatorSubscriber.prototype)), \"_complete\", _thisSuper3);\n    return _this;\n  }\n  _createClass(OperatorSubscriber, [{\n    key: \"unsubscribe\",\n    value: function unsubscribe() {\n      var _a;\n      if (!this.shouldUnsubscribe || this.shouldUnsubscribe()) {\n        var closed = this.closed;\n        _get(_getPrototypeOf(OperatorSubscriber.prototype), \"unsubscribe\", this).call(this);\n        !closed && ((_a = this.onFinalize) === null || _a === void 0 ? void 0 : _a.call(this));\n      }\n    }\n  }]);\n  return OperatorSubscriber;\n}(Subscriber);\n//# sourceMappingURL=OperatorSubscriber.js.map","map":null,"metadata":{},"sourceType":"module","externalDependencies":[]}