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
Last updated