From d55b767039605256c736166a942a9138e3eacfd7 Mon Sep 17 00:00:00 2001 From: Pinapelz Date: Sun, 29 Jun 2025 11:49:28 -0700 Subject: remove dev node_modules (oops) --- .../rxjs/dist/esm/internal/ReplaySubject.js | 50 ---------------------- 1 file changed, 50 deletions(-) delete mode 100644 node_modules/rxjs/dist/esm/internal/ReplaySubject.js (limited to 'node_modules/rxjs/dist/esm/internal/ReplaySubject.js') diff --git a/node_modules/rxjs/dist/esm/internal/ReplaySubject.js b/node_modules/rxjs/dist/esm/internal/ReplaySubject.js deleted file mode 100644 index 630f426..0000000 --- a/node_modules/rxjs/dist/esm/internal/ReplaySubject.js +++ /dev/null @@ -1,50 +0,0 @@ -import { Subject } from './Subject'; -import { dateTimestampProvider } from './scheduler/dateTimestampProvider'; -export class ReplaySubject extends Subject { - constructor(_bufferSize = Infinity, _windowTime = Infinity, _timestampProvider = dateTimestampProvider) { - super(); - this._bufferSize = _bufferSize; - this._windowTime = _windowTime; - this._timestampProvider = _timestampProvider; - this._buffer = []; - this._infiniteTimeWindow = true; - this._infiniteTimeWindow = _windowTime === Infinity; - this._bufferSize = Math.max(1, _bufferSize); - this._windowTime = Math.max(1, _windowTime); - } - next(value) { - const { isStopped, _buffer, _infiniteTimeWindow, _timestampProvider, _windowTime } = this; - if (!isStopped) { - _buffer.push(value); - !_infiniteTimeWindow && _buffer.push(_timestampProvider.now() + _windowTime); - } - this._trimBuffer(); - super.next(value); - } - _subscribe(subscriber) { - this._throwIfClosed(); - this._trimBuffer(); - const subscription = this._innerSubscribe(subscriber); - const { _infiniteTimeWindow, _buffer } = this; - const copy = _buffer.slice(); - for (let i = 0; i < copy.length && !subscriber.closed; i += _infiniteTimeWindow ? 1 : 2) { - subscriber.next(copy[i]); - } - this._checkFinalizedStatuses(subscriber); - return subscription; - } - _trimBuffer() { - const { _bufferSize, _timestampProvider, _buffer, _infiniteTimeWindow } = this; - const adjustedBufferSize = (_infiniteTimeWindow ? 1 : 2) * _bufferSize; - _bufferSize < Infinity && adjustedBufferSize < _buffer.length && _buffer.splice(0, _buffer.length - adjustedBufferSize); - if (!_infiniteTimeWindow) { - const now = _timestampProvider.now(); - let last = 0; - for (let i = 1; i < _buffer.length && _buffer[i] <= now; i += 2) { - last = i; - } - last && _buffer.splice(0, last + 1); - } - } -} -//# sourceMappingURL=ReplaySubject.js.map \ No newline at end of file -- cgit v1.2.3