aboutsummaryrefslogtreecommitdiff
path: root/tools/node_modules/eslint/node_modules/rxjs/internal/operators/sequenceEqual.js
diff options
context:
space:
mode:
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.js29
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);