diff --git a/src/CoreOperators.ts b/src/CoreOperators.ts index dfe4614624..5ea980e2cf 100644 --- a/src/CoreOperators.ts +++ b/src/CoreOperators.ts @@ -56,7 +56,7 @@ export interface CoreOperators { partition?: (predicate: (x: T) => boolean) => Observable[]; publish?: () => ConnectableObservable; publishBehavior?: (value: any) => ConnectableObservable; - publishReplay?: (bufferSize: number, windowTime: number, scheduler?: Scheduler) => ConnectableObservable; + publishReplay?: (bufferSize?: number, windowTime?: number, scheduler?: Scheduler) => ConnectableObservable; reduce?: (project: (acc: R, x: T) => R, seed?: R) => Observable; repeat?: (count?: number) => Observable; retry?: (count?: number) => Observable; @@ -91,4 +91,4 @@ export interface CoreOperators { withLatestFrom?: (...observables: Array | ((...values: Array) => R)>) => Observable; zip?: (...observables: Array | ((...values: Array) => R)>) => Observable; zipAll?: (project?: (...values: Array) => R) => Observable; -} \ No newline at end of file +} diff --git a/src/Observable.ts b/src/Observable.ts index d07061ecc3..20b3017573 100644 --- a/src/Observable.ts +++ b/src/Observable.ts @@ -210,7 +210,7 @@ export class Observable implements CoreOperators { partition: (predicate: (x: T) => boolean) => Observable[]; publish: () => ConnectableObservable; publishBehavior: (value: any) => ConnectableObservable; - publishReplay: (bufferSize: number, windowTime: number, scheduler?: Scheduler) => ConnectableObservable; + publishReplay: (bufferSize?: number, windowTime?: number, scheduler?: Scheduler) => ConnectableObservable; reduce: (project: (acc: R, x: T) => R, seed?: R) => Observable; repeat: (count?: number) => Observable; retry: (count?: number) => Observable;