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%2F_esm2015%2Finternal%2FReplaySubject.js;h=5bc6c760360ffde7fdc850b26bc65a3bfd49d288;hp=2acf607fef98c79fa8b3774185de0379949d886a;hb=4d07c77cf4d78cab8639e13ddc3c22495e585b0b;hpb=b3950616b54221c40a7dab9099bda675007e5b6e diff --git a/.config/coc/extensions/node_modules/coc-prettier/node_modules/rxjs/_esm2015/internal/ReplaySubject.js b/.config/coc/extensions/node_modules/coc-prettier/node_modules/rxjs/_esm2015/internal/ReplaySubject.js index 2acf607f..5bc6c760 100644 --- a/.config/coc/extensions/node_modules/coc-prettier/node_modules/rxjs/_esm2015/internal/ReplaySubject.js +++ b/.config/coc/extensions/node_modules/coc-prettier/node_modules/rxjs/_esm2015/internal/ReplaySubject.js @@ -21,16 +21,20 @@ export class ReplaySubject extends Subject { } } nextInfiniteTimeWindow(value) { - const _events = this._events; - _events.push(value); - if (_events.length > this._bufferSize) { - _events.shift(); + if (!this.isStopped) { + const _events = this._events; + _events.push(value); + if (_events.length > this._bufferSize) { + _events.shift(); + } } super.next(value); } nextTimeWindow(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.next(value); } _subscribe(subscriber) {