diff options
Diffstat (limited to 'sandbox/testAppNevena/Front/node_modules/rxjs/internal/operators/skipWhile.js')
| -rw-r--r-- | sandbox/testAppNevena/Front/node_modules/rxjs/internal/operators/skipWhile.js | 59 | 
1 files changed, 59 insertions, 0 deletions
| diff --git a/sandbox/testAppNevena/Front/node_modules/rxjs/internal/operators/skipWhile.js b/sandbox/testAppNevena/Front/node_modules/rxjs/internal/operators/skipWhile.js new file mode 100644 index 00000000..81963427 --- /dev/null +++ b/sandbox/testAppNevena/Front/node_modules/rxjs/internal/operators/skipWhile.js @@ -0,0 +1,59 @@ +"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 Subscriber_1 = require("../Subscriber"); +function skipWhile(predicate) { +    return function (source) { return source.lift(new SkipWhileOperator(predicate)); }; +} +exports.skipWhile = skipWhile; +var SkipWhileOperator = (function () { +    function SkipWhileOperator(predicate) { +        this.predicate = predicate; +    } +    SkipWhileOperator.prototype.call = function (subscriber, source) { +        return source.subscribe(new SkipWhileSubscriber(subscriber, this.predicate)); +    }; +    return SkipWhileOperator; +}()); +var SkipWhileSubscriber = (function (_super) { +    __extends(SkipWhileSubscriber, _super); +    function SkipWhileSubscriber(destination, predicate) { +        var _this = _super.call(this, destination) || this; +        _this.predicate = predicate; +        _this.skipping = true; +        _this.index = 0; +        return _this; +    } +    SkipWhileSubscriber.prototype._next = function (value) { +        var destination = this.destination; +        if (this.skipping) { +            this.tryCallPredicate(value); +        } +        if (!this.skipping) { +            destination.next(value); +        } +    }; +    SkipWhileSubscriber.prototype.tryCallPredicate = function (value) { +        try { +            var result = this.predicate(value, this.index++); +            this.skipping = Boolean(result); +        } +        catch (err) { +            this.destination.error(err); +        } +    }; +    return SkipWhileSubscriber; +}(Subscriber_1.Subscriber)); +//# sourceMappingURL=skipWhile.js.map
\ No newline at end of file | 
