rxjs - npm Package Compare versions

Comparing version 6.6.2 to 6.6.3

_esm2015/internal/ReplaySubject.js

@@ -24,6 +24,8 @@ import { Subject } from './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();
+            }
         }
@@ -33,4 +35,6 @@ 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);
@@ -37,0 +41,0 @@ }

_esm5/internal/ReplaySubject.js

@@ -34,6 +34,8 @@ /** PURE_IMPORTS_START tslib,_Subject,_scheduler_queue,_Subscription,_operators_observeOn,_util_ObjectUnsubscribedError,_SubjectSubscription PURE_IMPORTS_END */
     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();
+            }
         }
@@ -43,4 +45,6 @@ _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);
@@ -47,0 +51,0 @@ };

internal/ReplaySubject.js

@@ -43,6 +43,8 @@ "use strict";
     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();
+            }
         }
@@ -52,4 +54,6 @@ _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);
@@ -56,0 +60,0 @@ };

package.json

 {
   "name": "rxjs",
-  "version": "6.6.2",
+  "version": "6.6.3",
   "description": "Reactive Extensions for modern JavaScript",
@@ -155,3 +155,3 @@ "main": "./index.js",
     "rxjs": "^5.5.7",
-    "shx": "0.2.2",
+    "shx": "^0.3.2",
     "sinon": "4.3.0",
@@ -158,0 +158,0 @@ "sinon-chai": "2.14.0",

src/internal/ReplaySubject.ts

@@ -38,10 +38,11 @@ import { Subject } from './Subject';
   private nextInfiniteTimeWindow(value: T): void {
-    const _events = this._events;
-    _events.push(value);
-    // Since this method is invoked in every next() call than the buffer
-    // can overgrow the max size only by one item
-    if (_events.length > this._bufferSize) {
-      _events.shift();
+    if (!this.isStopped) {
+      const _events = this._events;
+      _events.push(value);
+      // Since this method is invoked in every next() call than the buffer
+      // can overgrow the max size only by one item
+      if (_events.length > this._bufferSize) {
+        _events.shift();
+      }
     }
-
     super.next(value);
@@ -51,5 +52,6 @@ }
   private nextTimeWindow(value: T): void {
-    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);
@@ -56,0 +58,0 @@ }

No alert changes

Improved metrics

Total package byte prevSize

5121936

0.02%

Lines of code

71621

0.03%

No dependency changes