Giant blob of minor changes

[dotfiles/.git] / .config / coc / extensions / node_modules / coc-prettier / node_modules / rxjs / internal / ReplaySubject.js

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 673884f3c6ad2bb47f5cb9c2aadfe35cc3539ac8..610c87a058023ac000096a9a7d9c9eb46af4b7e5 100644 (file)
--- 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) {