1 | import { Subject } from './Subject';
|
2 | import { SchedulerLike } from './types';
|
3 | import { Subscriber } from './Subscriber';
|
4 | import { Subscription } from './Subscription';
|
5 |
|
6 |
|
7 |
|
8 |
|
9 |
|
10 |
|
11 |
|
12 | export declare class ReplaySubject<T> extends Subject<T> {
|
13 | private scheduler?;
|
14 | private _events;
|
15 | private _bufferSize;
|
16 | private _windowTime;
|
17 | private _infiniteTimeWindow;
|
18 | constructor(bufferSize?: number, windowTime?: number, scheduler?: SchedulerLike);
|
19 | private nextInfiniteTimeWindow;
|
20 | private nextTimeWindow;
|
21 | /** @deprecated This is an internal implementation detail, do not use. */
|
22 | _subscribe(subscriber: Subscriber<T>): Subscription;
|
23 | _getNow(): number;
|
24 | private _trimBufferThenGetEvents;
|
25 | }
|