Make signature of .publishReplay() consistent with publishReplay()

kwonoj · Nov 19, 2015 · 3f85538 · 3f85538
1 parent 505f5b7
commit 3f85538
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 3 deletions.
diff --git a/src/CoreOperators.ts b/src/CoreOperators.ts
@@ -56,7 +56,7 @@ export interface CoreOperators<T> {
  partition?: (predicate: (x: T) => boolean) => Observable<T>[];
  publish?: () => ConnectableObservable<T>;
  publishBehavior?: (value: any) => ConnectableObservable<T>;
- publishReplay?: (bufferSize: number, windowTime: number, scheduler?: Scheduler) => ConnectableObservable<T>;
+ publishReplay?: (bufferSize?: number, windowTime?: number, scheduler?: Scheduler) => ConnectableObservable<T>;
  reduce?: <R>(project: (acc: R, x: T) => R, seed?: R) => Observable<R>;
  repeat?: (count?: number) => Observable<T>;
  retry?: (count?: number) => Observable<T>;
@@ -91,4 +91,4 @@ export interface CoreOperators<T> {
  withLatestFrom?: <R>(...observables: Array<Observable<any> | ((...values: Array<any>) => R)>) => Observable<R>;
  zip?: <R>(...observables: Array<Observable<any> | ((...values: Array<any>) => R)>) => Observable<R>;
  zipAll?: <R>(project?: (...values: Array<any>) => R) => Observable<R>;
-}
+}
diff --git a/src/Observable.ts b/src/Observable.ts
@@ -210,7 +210,7 @@ export class Observable<T> implements CoreOperators<T> {
  partition: (predicate: (x: T) => boolean) => Observable<T>[];
  publish: () => ConnectableObservable<T>;
  publishBehavior: (value: any) => ConnectableObservable<T>;
- publishReplay: (bufferSize: number, windowTime: number, scheduler?: Scheduler) => ConnectableObservable<T>;
+ publishReplay: (bufferSize?: number, windowTime?: number, scheduler?: Scheduler) => ConnectableObservable<T>;
  reduce: <R>(project: (acc: R, x: T) => R, seed?: R) => Observable<R>;
  repeat: (count?: number) => Observable<T>;
  retry: (count?: number) => Observable<T>;