fix(typings): relax throttle selector type

Closes ReactiveX#3204
cartant · Jan 13, 2018 · c75d437 · c75d437
1 parent fac9460
commit c75d437
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 4 deletions.
diff --git a/src/internal/operators/throttle.ts b/src/internal/operators/throttle.ts
@@ -59,13 +59,13 @@ export const defaultThrottleConfig: ThrottleConfig = {
  * @method throttle
  * @owner Observable
  */
-export function throttle<T>(durationSelector: (value: T) => SubscribableOrPromise<number>,
+export function throttle<T>(durationSelector: (value: T) => SubscribableOrPromise<any>,
                             config: ThrottleConfig = defaultThrottleConfig): MonoTypeOperatorFunction<T> {
   return (source: Observable<T>) => source.lift(new ThrottleOperator(durationSelector, config.leading, config.trailing));
 }
 
 class ThrottleOperator<T> implements Operator<T, T> {
-  constructor(private durationSelector: (value: T) => SubscribableOrPromise<number>,
+  constructor(private durationSelector: (value: T) => SubscribableOrPromise<any>,
               private leading: boolean,
               private trailing: boolean) {
   }
@@ -88,7 +88,7 @@ class ThrottleSubscriber<T, R> extends OuterSubscriber<T, R> {
   private _hasTrailingValue = false;
 
   constructor(protected destination: Subscriber<T>,
-              private durationSelector: (value: T) => SubscribableOrPromise<number>,
+              private durationSelector: (value: T) => SubscribableOrPromise<any>,
               private _leading: boolean,
               private _trailing: boolean) {
     super(destination);

diff --git a/src/internal/patching/operator/throttle.ts b/src/internal/patching/operator/throttle.ts
@@ -42,7 +42,7 @@ import { throttle as higherOrder, ThrottleConfig, defaultThrottleConfig } from '
  * @owner Observable
  */
 export function throttle<T>(this: Observable<T>,
-                            durationSelector: (value: T) => SubscribableOrPromise<number>,
+                            durationSelector: (value: T) => SubscribableOrPromise<any>,
                             config: ThrottleConfig = defaultThrottleConfig): Observable<T> {
   return higherOrder(durationSelector, config)(this);
 }