diff options
| author | Danijel Andjelkovic <adanijel99@gmail.com> | 2022-03-01 21:54:41 +0100 | 
|---|---|---|
| committer | Danijel Andjelkovic <adanijel99@gmail.com> | 2022-03-01 21:54:41 +0100 | 
| commit | 6c8128f9fd5a5d0be115806c35a21b3d683df8d6 (patch) | |
| tree | f46c2f6b3b9b294ff32bd75c08ccdc9e7a8cc4ef /sandbox/testAppNevena/Front/node_modules/rxjs/internal/operators/throwIfEmpty.js | |
| parent | 2400b84e95913665da6279114168148444b8f9ab (diff) | |
| parent | 7d3640f824f46490b47bd95f1c5a16644f712068 (diff) | |
Merge branch 'dev' of http://gitlab.pmf.kg.ac.rs/igrannonica/neuronstellar into logo
Diffstat (limited to 'sandbox/testAppNevena/Front/node_modules/rxjs/internal/operators/throwIfEmpty.js')
| -rw-r--r-- | sandbox/testAppNevena/Front/node_modules/rxjs/internal/operators/throwIfEmpty.js | 66 | 
1 files changed, 66 insertions, 0 deletions
| diff --git a/sandbox/testAppNevena/Front/node_modules/rxjs/internal/operators/throwIfEmpty.js b/sandbox/testAppNevena/Front/node_modules/rxjs/internal/operators/throwIfEmpty.js new file mode 100644 index 00000000..7722c349 --- /dev/null +++ b/sandbox/testAppNevena/Front/node_modules/rxjs/internal/operators/throwIfEmpty.js @@ -0,0 +1,66 @@ +"use strict"; +var __extends = (this && this.__extends) || (function () { +    var extendStatics = function (d, b) { +        extendStatics = Object.setPrototypeOf || +            ({ __proto__: [] } instanceof Array && function (d, b) { d.__proto__ = b; }) || +            function (d, b) { for (var p in b) if (b.hasOwnProperty(p)) d[p] = b[p]; }; +        return extendStatics(d, b); +    } +    return function (d, b) { +        extendStatics(d, b); +        function __() { this.constructor = d; } +        d.prototype = b === null ? Object.create(b) : (__.prototype = b.prototype, new __()); +    }; +})(); +Object.defineProperty(exports, "__esModule", { value: true }); +var EmptyError_1 = require("../util/EmptyError"); +var Subscriber_1 = require("../Subscriber"); +function throwIfEmpty(errorFactory) { +    if (errorFactory === void 0) { errorFactory = defaultErrorFactory; } +    return function (source) { +        return source.lift(new ThrowIfEmptyOperator(errorFactory)); +    }; +} +exports.throwIfEmpty = throwIfEmpty; +var ThrowIfEmptyOperator = (function () { +    function ThrowIfEmptyOperator(errorFactory) { +        this.errorFactory = errorFactory; +    } +    ThrowIfEmptyOperator.prototype.call = function (subscriber, source) { +        return source.subscribe(new ThrowIfEmptySubscriber(subscriber, this.errorFactory)); +    }; +    return ThrowIfEmptyOperator; +}()); +var ThrowIfEmptySubscriber = (function (_super) { +    __extends(ThrowIfEmptySubscriber, _super); +    function ThrowIfEmptySubscriber(destination, errorFactory) { +        var _this = _super.call(this, destination) || this; +        _this.errorFactory = errorFactory; +        _this.hasValue = false; +        return _this; +    } +    ThrowIfEmptySubscriber.prototype._next = function (value) { +        this.hasValue = true; +        this.destination.next(value); +    }; +    ThrowIfEmptySubscriber.prototype._complete = function () { +        if (!this.hasValue) { +            var err = void 0; +            try { +                err = this.errorFactory(); +            } +            catch (e) { +                err = e; +            } +            this.destination.error(err); +        } +        else { +            return this.destination.complete(); +        } +    }; +    return ThrowIfEmptySubscriber; +}(Subscriber_1.Subscriber)); +function defaultErrorFactory() { +    return new EmptyError_1.EmptyError(); +} +//# sourceMappingURL=throwIfEmpty.js.map
\ No newline at end of file | 
