projects
/
dotfiles
/
.git
/ blobdiff
commit
grep
author
committer
pickaxe
?
search:
re
summary
|
shortlog
|
log
|
commit
|
commitdiff
|
tree
raw
|
inline
| side by side
Giant blob of minor changes
[dotfiles/.git]
/
.config
/
coc
/
extensions
/
node_modules
/
coc-prettier
/
node_modules
/
rxjs
/
internal
/
operators
/
exhaust.js
diff --git
a/.config/coc/extensions/node_modules/coc-prettier/node_modules/rxjs/internal/operators/exhaust.js
b/.config/coc/extensions/node_modules/coc-prettier/node_modules/rxjs/internal/operators/exhaust.js
index 8b1c1ef4d99094c78073d6a4dbb32ed6bf6c8beb..b42928e557867b5b5f411d70f99f063b1d5a2503 100644
(file)
--- a/
.config/coc/extensions/node_modules/coc-prettier/node_modules/rxjs/internal/operators/exhaust.js
+++ b/
.config/coc/extensions/node_modules/coc-prettier/node_modules/rxjs/internal/operators/exhaust.js
@@
-13,8
+13,7
@@
var __extends = (this && this.__extends) || (function () {
};
})();
Object.defineProperty(exports, "__esModule", { value: true });
};
})();
Object.defineProperty(exports, "__esModule", { value: true });
-var OuterSubscriber_1 = require("../OuterSubscriber");
-var subscribeToResult_1 = require("../util/subscribeToResult");
+var innerSubscribe_1 = require("../innerSubscribe");
function exhaust() {
return function (source) { return source.lift(new SwitchFirstOperator()); };
}
function exhaust() {
return function (source) { return source.lift(new SwitchFirstOperator()); };
}
@@
-38,7
+37,7
@@
var SwitchFirstSubscriber = (function (_super) {
SwitchFirstSubscriber.prototype._next = function (value) {
if (!this.hasSubscription) {
this.hasSubscription = true;
SwitchFirstSubscriber.prototype._next = function (value) {
if (!this.hasSubscription) {
this.hasSubscription = true;
- this.add(
subscribeToResult_1.subscribeToResult(this, value
));
+ this.add(
innerSubscribe_1.innerSubscribe(value, new innerSubscribe_1.SimpleInnerSubscriber(this)
));
}
};
SwitchFirstSubscriber.prototype._complete = function () {
}
};
SwitchFirstSubscriber.prototype._complete = function () {
@@
-47,13
+46,12
@@
var SwitchFirstSubscriber = (function (_super) {
this.destination.complete();
}
};
this.destination.complete();
}
};
- SwitchFirstSubscriber.prototype.notifyComplete = function (innerSub) {
- this.remove(innerSub);
+ SwitchFirstSubscriber.prototype.notifyComplete = function () {
this.hasSubscription = false;
if (this.hasCompleted) {
this.destination.complete();
}
};
return SwitchFirstSubscriber;
this.hasSubscription = false;
if (this.hasCompleted) {
this.destination.complete();
}
};
return SwitchFirstSubscriber;
-}(
OuterSubscriber_1.
OuterSubscriber));
+}(
innerSubscribe_1.Simple
OuterSubscriber));
//# sourceMappingURL=exhaust.js.map
\ No newline at end of file
//# sourceMappingURL=exhaust.js.map
\ No newline at end of file