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
Copy 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 >;
} 