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
/
_esm5
/
internal
/
ReplaySubject.js
diff --git
a/.config/coc/extensions/node_modules/coc-prettier/node_modules/rxjs/_esm5/internal/ReplaySubject.js
b/.config/coc/extensions/node_modules/coc-prettier/node_modules/rxjs/_esm5/internal/ReplaySubject.js
index 7cd229affd85f4ad7d65fbe7d87fc94ed3f401d7..6fa3479b1f43270bb86c7eb70e17b95c9e807e9a 100644
(file)
--- a/
.config/coc/extensions/node_modules/coc-prettier/node_modules/rxjs/_esm5/internal/ReplaySubject.js
+++ b/
.config/coc/extensions/node_modules/coc-prettier/node_modules/rxjs/_esm5/internal/ReplaySubject.js
@@
-31,16
+31,20
@@
var ReplaySubject = /*@__PURE__*/ (function (_super) {
return _this;
}
ReplaySubject.prototype.nextInfiniteTimeWindow = function (value) {
return _this;
}
ReplaySubject.prototype.nextInfiniteTimeWindow = function (value) {
- var _events = this._events;
- _events.push(value);
- if (_events.length > this._bufferSize) {
- _events.shift();
+ if (!this.isStopped) {
+ var _events = this._events;
+ _events.push(value);
+ if (_events.length > this._bufferSize) {
+ _events.shift();
+ }
}
_super.prototype.next.call(this, value);
};
ReplaySubject.prototype.nextTimeWindow = function (value) {
}
_super.prototype.next.call(this, value);
};
ReplaySubject.prototype.nextTimeWindow = function (value) {
- this._events.push(new ReplayEvent(this._getNow(), value));
- this._trimBufferThenGetEvents();
+ if (!this.isStopped) {
+ this._events.push(new ReplayEvent(this._getNow(), value));
+ this._trimBufferThenGetEvents();
+ }
_super.prototype.next.call(this, value);
};
ReplaySubject.prototype._subscribe = function (subscriber) {
_super.prototype.next.call(this, value);
};
ReplaySubject.prototype._subscribe = function (subscriber) {