diff options
Diffstat (limited to 'tools/node_modules/eslint/node_modules/rxjs/internal/operators/sequenceEqual.js')
-rw-r--r-- | tools/node_modules/eslint/node_modules/rxjs/internal/operators/sequenceEqual.js | 29 |
1 files changed, 12 insertions, 17 deletions
diff --git a/tools/node_modules/eslint/node_modules/rxjs/internal/operators/sequenceEqual.js b/tools/node_modules/eslint/node_modules/rxjs/internal/operators/sequenceEqual.js index badbfe84d5..dbb6bce058 100644 --- a/tools/node_modules/eslint/node_modules/rxjs/internal/operators/sequenceEqual.js +++ b/tools/node_modules/eslint/node_modules/rxjs/internal/operators/sequenceEqual.js @@ -14,29 +14,27 @@ var __extends = (this && this.__extends) || (function () { })(); Object.defineProperty(exports, "__esModule", { value: true }); var Subscriber_1 = require("../Subscriber"); -var tryCatch_1 = require("../util/tryCatch"); -var errorObject_1 = require("../util/errorObject"); -function sequenceEqual(compareTo, comparor) { - return function (source) { return source.lift(new SequenceEqualOperator(compareTo, comparor)); }; +function sequenceEqual(compareTo, comparator) { + return function (source) { return source.lift(new SequenceEqualOperator(compareTo, comparator)); }; } exports.sequenceEqual = sequenceEqual; var SequenceEqualOperator = (function () { - function SequenceEqualOperator(compareTo, comparor) { + function SequenceEqualOperator(compareTo, comparator) { this.compareTo = compareTo; - this.comparor = comparor; + this.comparator = comparator; } SequenceEqualOperator.prototype.call = function (subscriber, source) { - return source.subscribe(new SequenceEqualSubscriber(subscriber, this.compareTo, this.comparor)); + return source.subscribe(new SequenceEqualSubscriber(subscriber, this.compareTo, this.comparator)); }; return SequenceEqualOperator; }()); exports.SequenceEqualOperator = SequenceEqualOperator; var SequenceEqualSubscriber = (function (_super) { __extends(SequenceEqualSubscriber, _super); - function SequenceEqualSubscriber(destination, compareTo, comparor) { + function SequenceEqualSubscriber(destination, compareTo, comparator) { var _this = _super.call(this, destination) || this; _this.compareTo = compareTo; - _this.comparor = comparor; + _this.comparator = comparator; _this._a = []; _this._b = []; _this._oneComplete = false; @@ -62,19 +60,16 @@ var SequenceEqualSubscriber = (function (_super) { this.unsubscribe(); }; SequenceEqualSubscriber.prototype.checkValues = function () { - var _c = this, _a = _c._a, _b = _c._b, comparor = _c.comparor; + var _c = this, _a = _c._a, _b = _c._b, comparator = _c.comparator; while (_a.length > 0 && _b.length > 0) { var a = _a.shift(); var b = _b.shift(); var areEqual = false; - if (comparor) { - areEqual = tryCatch_1.tryCatch(comparor)(a, b); - if (areEqual === errorObject_1.errorObject) { - this.destination.error(errorObject_1.errorObject.e); - } + try { + areEqual = comparator ? comparator(a, b) : a === b; } - else { - areEqual = a === b; + catch (e) { + this.destination.error(e); } if (!areEqual) { this.emit(false); |