1 | import { Observable, SchedulerLike } from 'rxjs';
|
2 | import { shareReplay as higherOrder } from 'rxjs/operators';
|
3 | import { ShareReplayConfig } from 'rxjs/internal-compatibility';
|
4 |
|
5 |
|
6 |
|
7 |
|
8 |
|
9 | export function shareReplay<T>(this: Observable<T>, config: ShareReplayConfig): Observable<T>;
|
10 | export function shareReplay<T>(this: Observable<T>, bufferSize?: number, windowTime?: number, scheduler?: SchedulerLike): Observable<T>;
|
11 | export function shareReplay<T>(this: Observable<T>, configOrBufferSize?: ShareReplayConfig | number, windowTime?: number, scheduler?: SchedulerLike):
|
12 | Observable<T> {
|
13 | if (configOrBufferSize && typeof configOrBufferSize === 'object') {
|
14 | return higherOrder(configOrBufferSize as ShareReplayConfig)(this) as Observable<T>;
|
15 | }
|
16 | return higherOrder(configOrBufferSize as number | undefined, windowTime, scheduler)(this) as Observable<T>;
|
17 | }
|