UNPKG

903 BPlain TextView Raw
1import { Observable, SchedulerLike } from 'rxjs';
2import { shareReplay as higherOrder } from 'rxjs/operators';
3import { ShareReplayConfig } from 'rxjs/internal-compatibility';
4
5/**
6 * @method shareReplay
7 * @owner Observable
8 */
9export function shareReplay<T>(this: Observable<T>, config: ShareReplayConfig): Observable<T>;
10export function shareReplay<T>(this: Observable<T>, bufferSize?: number, windowTime?: number, scheduler?: SchedulerLike): Observable<T>;
11export 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}