rxjs
Advanced tools
Comparing version 6.6.2 to 6.6.3
@@ -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 @@ } |
@@ -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 @@ }; |
@@ -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 @@ }; |
{ | ||
"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", |
@@ -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 @@ } |
Sorry, the diff of this file is not supported yet
Sorry, the diff of this file is not supported yet
Sorry, the diff of this file is too big to display
Sorry, the diff of this file is not supported yet
Sorry, the diff of this file is too big to display
Sorry, the diff of this file is not supported yet
Sorry, the diff of this file is not supported yet
5121936
71621