Gecko [ unitednationsplay.com ]

Name	Size	Permission	Date
add	[ DIR ]	drwxrwxr-x	2022-08-30 11:49
observable	[ DIR ]	drwxrwxr-x	2022-08-30 11:49
operator	[ DIR ]	drwxrwxr-x	2022-08-30 11:49
operators	[ DIR ]	drwxrwxr-x	2022-08-30 11:49
scheduler	[ DIR ]	drwxrwxr-x	2022-08-30 11:49
symbol	[ DIR ]	drwxrwxr-x	2022-08-30 11:49
testing	[ DIR ]	drwxrwxr-x	2022-08-30 11:49
util	[ DIR ]	drwxrwxr-x	2022-08-30 11:49
AsyncSubject.ts	1.04 KB	-rw-rw-r--	2022-08-30 11:49
BUILD.bazel	650 B	-rw-rw-r--	2022-08-30 11:49
BehaviorSubject.ts	962 B	-rw-rw-r--	2022-08-30 11:49
InnerSubscriber.ts	742 B	-rw-rw-r--	2022-08-30 11:49
LICENSE.txt	10.8 KB	-rw-rw-r--	2022-08-30 11:49
MiscJSDoc.ts	15.3 KB	-rw-rw-r--	2022-08-30 11:49
Notification.ts	4.32 KB	-rw-rw-r--	2022-08-30 11:49
Observable.ts	14.9 KB	-rw-rw-r--	2022-08-30 11:49
Observer.ts	828 B	-rw-rw-r--	2022-08-30 11:49
Operator.ts	191 B	-rw-rw-r--	2022-08-30 11:49
OuterSubscriber.ts	646 B	-rw-rw-r--	2022-08-30 11:49
README.md	7.27 KB	-rw-rw-r--	2022-08-30 11:49
ReplaySubject.ts	2.94 KB	-rw-rw-r--	2022-08-30 11:49
Rx.global.js	137 B	-rw-rw-r--	2022-08-30 11:49
Rx.ts	8.16 KB	-rw-rw-r--	2022-08-30 11:49
Scheduler.ts	2.29 KB	-rw-rw-r--	2022-08-30 11:49
Subject.ts	4.04 KB	-rw-rw-r--	2022-08-30 11:49
SubjectSubscription.ts	849 B	-rw-rw-r--	2022-08-30 11:49
Subscriber.ts	8.63 KB	-rw-rw-r--	2022-08-30 11:49
Subscription.ts	7.08 KB	-rw-rw-r--	2022-08-30 11:49
WORKSPACE	25 B	-rw-rw-r--	2022-08-30 11:49
interfaces.ts	294 B	-rw-rw-r--	2022-08-30 11:49
operators.ts	5.27 KB	-rw-rw-r--	2022-08-30 11:49
tsconfig.json	640 B	-rw-rw-r--	2022-08-30 11:49

Rename

import { Subject } from './Subject';
import { IScheduler } from './Scheduler';
import { queue } from './scheduler/queue';
import { Subscriber } from './Subscriber';
import { Subscription } from './Subscription';
import { ObserveOnSubscriber } from './operators/observeOn';
import { ObjectUnsubscribedError } from './util/ObjectUnsubscribedError';
import { SubjectSubscription } from './SubjectSubscription';
/**
 * @class ReplaySubject<T>
 */
export class ReplaySubject<T> extends Subject<T> {
  private _events: ReplayEvent<T>[] = [];
  private _bufferSize: number;
  private _windowTime: number;

constructor(bufferSize: number = Number.POSITIVE_INFINITY,
              windowTime: number = Number.POSITIVE_INFINITY,
              private scheduler?: IScheduler) {
    super();
    this._bufferSize = bufferSize < 1 ? 1 : bufferSize;
    this._windowTime = windowTime < 1 ? 1 : windowTime;
  }

next(value: T): void {
    const now = this._getNow();
    this._events.push(new ReplayEvent(now, value));
    this._trimBufferThenGetEvents();
    super.next(value);
  }

/** @deprecated internal use only */ _subscribe(subscriber: Subscriber<T>): Subscription {
    const _events = this._trimBufferThenGetEvents();
    const scheduler = this.scheduler;
    let subscription: Subscription;

if (this.closed) {
      throw new ObjectUnsubscribedError();
    } else if (this.hasError) {
      subscription = Subscription.EMPTY;
    } else if (this.isStopped) {
      subscription = Subscription.EMPTY;
    } else {
      this.observers.push(subscriber);
      subscription = new SubjectSubscription(this, subscriber);
    }

if (scheduler) {
      subscriber.add(subscriber = new ObserveOnSubscriber<T>(subscriber, scheduler));
    }

const len = _events.length;
    for (let i = 0; i < len && !subscriber.closed; i++) {
      subscriber.next(_events[i].value);
    }

if (this.hasError) {
      subscriber.error(this.thrownError);
    } else if (this.isStopped) {
      subscriber.complete();
    }

return subscription;
  }

_getNow(): number {
    return (this.scheduler || queue).now();
  }

private _trimBufferThenGetEvents(): ReplayEvent<T>[] {
    const now = this._getNow();
    const _bufferSize = this._bufferSize;
    const _windowTime = this._windowTime;
    const _events = this._events;

let eventsCount = _events.length;
    let spliceCount = 0;

// Trim events that fall out of the time window.
    // Start at the front of the list. Break early once
    // we encounter an event that falls within the window.
    while (spliceCount < eventsCount) {
      if ((now - _events[spliceCount].time) < _windowTime) {
        break;
      }
      spliceCount++;
    }

if (eventsCount > _bufferSize) {
      spliceCount = Math.max(spliceCount, eventsCount - _bufferSize);
    }

if (spliceCount > 0) {
      _events.splice(0, spliceCount);
    }

return _events;
  }
}

class ReplayEvent<T> {
  constructor(public time: number, public value: T) {
  }
}