ReplaySubject

Un tipo de Sujeto que "repite" o reemite valores antiguos a suscriptores nuevos. Almacena un número determinado de valores en un búfer y emite dichos valores inmediatamente a cualquier suscriptor nuevo, además de emitir nuevos valores a los suscriptores existentes

class ReplaySubject<T> extends Subject {
  constructor(
    bufferSize: number = Number.POSITIVE_INFINITY,
    windowTime: number = Number.POSITIVE_INFINITY,
    scheduler?: SchedulerLike
  );
  _subscribe(subscriber: Subscriber<T>): Subscription;
  _getNow(): number;

  // inherited from index/Subject
  static create: Function;
  constructor();
  observers: Observer<T>[];
  closed: false;
  isStopped: false;
  hasError: false;
  thrownError: any;
  lift<R>(operator: Operator<T, R>): Observable<R>;
  next(value?: T);
  error(err: any);
  complete();
  unsubscribe();
  _trySubscribe(subscriber: Subscriber<T>): TeardownLogic;
  _subscribe(subscriber: Subscriber<T>): Subscription;
  asObservable(): Observable<T>;

  // inherited from index/Observable
  static create: Function;
  static if: typeof iif;
  static throw: typeof throwError;
  constructor(
    subscribe?: (
      this: Observable<T>,
      subscriber: Subscriber<T>
    ) => TeardownLogic
  );
  _isScalar: boolean;
  source: Observable<any>;
  operator: Operator<any, T>;
  lift<R>(operator: Operator<T, R>): Observable<R>;
  subscribe(
    observerOrNext?:
      | NextObserver<T>
      | ErrorObserver<T>
      | CompletionObserver<T>
      | ((value: T) => void),
    error?: (error: any) => void,
    complete?: () => void
  ): Subscription;
  _trySubscribe(sink: Subscriber<T>): TeardownLogic;
  forEach(
    next: (value: T) => void,
    promiseCtor?: PromiseConstructorLike
  ): Promise<void>;
  pipe(...operations: OperatorFunction<any, any>[]): Observable<any>;
  toPromise(promiseCtor?: PromiseConstructorLike): Promise<T>;
}

Constructor

constructor()
Firma constructor(bufferSize: number = Number.POSITIVE_INFINITY, windowTime: number = Number.POSITIVE_INFINITY, scheduler?: SchedulerLike) Parámetros bufferSize Opcional. El valor por defecto es Number.POSITIVE_INFINITY. Tipo: number. windowTime Opcional. El valor por defecto es Number.POSITIVE_INFINITY. Tipo: number. scheduler Opcional. El valor por defecto es undefined. Tipo: SchedulerLike.
bufferSize	Opcional. El valor por defecto es Number.POSITIVE_INFINITY. Tipo: number.
windowTime	Opcional. El valor por defecto es Number.POSITIVE_INFINITY. Tipo: number.
scheduler	Opcional. El valor por defecto es undefined. Tipo: SchedulerLike.

Métodos

_subscribe()
Firma _subscribe(subscriber: Subscriber): Subscription Parámetros subscriber Tipo: Subscriber. Retorna Subscription
subscriber	Tipo: Subscriber.

_getNow()
Firma _getNow(): number Parámetros No recibe ningún parámetro. Retorna number