diff --git a/src/observable/bindNodeCallback.ts b/src/observable/bindNodeCallback.ts index 085c681b7f..ac7f4a2a89 100644 --- a/src/observable/bindNodeCallback.ts +++ b/src/observable/bindNodeCallback.ts @@ -12,13 +12,13 @@ export class BoundNodeCallbackObservable extends Observable { static create(callbackFunc: Function, selector: Function = undefined, scheduler?: Scheduler): Function { - return (...args): Observable => { + return (...args: any[]): Observable => { return new BoundNodeCallbackObservable(callbackFunc, selector, args, scheduler); }; } constructor(private callbackFunc: Function, - private selector, + private selector: Function, private args: any[], public scheduler: Scheduler) { super(); @@ -33,7 +33,7 @@ export class BoundNodeCallbackObservable extends Observable { if (!scheduler) { if (!subject) { subject = this.subject = new AsyncSubject(); - const handler = function handlerFn(...innerArgs) { + const handler = function handlerFn(...innerArgs: any[]) { const source = (handlerFn).source; const { selector, subject } = source; const err = innerArgs.shift(); @@ -77,7 +77,7 @@ function dispatch(state: { source: BoundNodeCallbackObservable, subscriber if (!subject) { subject = source.subject = new AsyncSubject(); - const handler = function handlerFn(...innerArgs) { + const handler = function handlerFn(...innerArgs: any[]) { const source = (handlerFn).source; const { selector, subject } = source; const err = innerArgs.shift();