X-Git-Url: https://git.josue.xyz/?p=dotfiles%2F.git;a=blobdiff_plain;f=.config%2Fcoc%2Fextensions%2Fnode_modules%2Fcoc-prettier%2Fnode_modules%2Frxjs%2Finternal%2FReplaySubject.js;h=610c87a058023ac000096a9a7d9c9eb46af4b7e5;hp=673884f3c6ad2bb47f5cb9c2aadfe35cc3539ac8;hb=4d07c77cf4d78cab8639e13ddc3c22495e585b0b;hpb=b3950616b54221c40a7dab9099bda675007e5b6e diff --git a/.config/coc/extensions/node_modules/coc-prettier/node_modules/rxjs/internal/ReplaySubject.js b/.config/coc/extensions/node_modules/coc-prettier/node_modules/rxjs/internal/ReplaySubject.js index 673884f3..610c87a0 100644 --- a/.config/coc/extensions/node_modules/coc-prettier/node_modules/rxjs/internal/ReplaySubject.js +++ b/.config/coc/extensions/node_modules/coc-prettier/node_modules/rxjs/internal/ReplaySubject.js @@ -40,16 +40,20 @@ var ReplaySubject = (function (_super) { 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) { - 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) {