Fixed a few places where errors would pop-up with noImplcityAny

Author: david-driscoll

ts/core/concurrency/scheduleperiodicrecursive.ts

@@ -6,7 +6,7 @@ module Rx {
         }
 
         interface SchedulePeriodicRecursiveStatic {
-            new (scheduler, state, period, action) : SchedulePeriodicRecursive;
+            new (scheduler: any, state: any, period: any, action: any) : SchedulePeriodicRecursive;
         }
 
         export var SchedulePeriodicRecursive: SchedulePeriodicRecursiveStatic;

ts/core/internal/util.ts

@@ -2,8 +2,8 @@
 /// <reference path="../observable.ts" />
 module Rx {
     export module internals {
-        export var inherits: (child, parent) => void;
-        export var addProperties: (obj, ...sources: any[]) => void;
+        export var inherits: (child: any, parent: any) => void;
+        export var addProperties: (obj: any, ...sources: any[]) => void;
         export var addRef: <T>(xs: Observable<T>, r: { getDisposable(): IDisposable; }) => Observable<T>;
     }
 }

ts/core/linq/observable/transduce.ts

@@ -6,7 +6,7 @@ module Rx {
          * @param {Transducer} transducer A transducer to execute
          * @returns {Observable} An Observable sequence containing the results from the transducer.
          */
-        transduce(transducer: any);
+        transduce(transducer: any): any;
         //TODO: Setup transducer
     }
 }

ts/core/notification.ts

@@ -45,7 +45,7 @@ module Rx {
     }
 
     interface NotificationStatic {
-        new <T>(kind, value, exception, accept, acceptObservable, toString) : Notification<T>;
+        new <T>(kind: any, value: any, exception: any, accept: any, acceptObservable: any, toString: any) : Notification<T>;
 
         /**
         * Creates an object that represents an OnNext notification to an observer.

ts/core/testing/reactivetest.ts

@@ -79,9 +79,9 @@ module Rx {
     var n : number = Rx.ReactiveTest.disposed;
 
     var r : Rx.Recorded = Rx.ReactiveTest.onNext(100, 'abc');
-    var r : Rx.Recorded = Rx.ReactiveTest.onNext(100, (v) => false);
+    var r : Rx.Recorded = Rx.ReactiveTest.onNext(100, (v: any) => false);
     var r : Rx.Recorded = Rx.ReactiveTest.onError(100, new Error('abc'));
-    var r : Rx.Recorded = Rx.ReactiveTest.onError(100, (v) => true);
+    var r : Rx.Recorded = Rx.ReactiveTest.onError(100, (v: any) => true);
     var r : Rx.Recorded = Rx.ReactiveTest.onCompleted(100);
 
     var s : Rx.Subscription = Rx.ReactiveTest.subscribe(100);

ts/core/testing/subscription.ts

@@ -21,7 +21,7 @@ module Rx {
          * @param {Number} subscribe Virtual time at which the subscription occurred.
          * @param {Number} unsubscribe Virtual time at which the unsubscription occurred.
          */
-        new (subscribeAt: number, unsubscribeAt?: number);
+        new (subscribeAt: number, unsubscribeAt?: number): Subscription;
     }
 
     export var Subscription: SubscriptionStatic;

ts/tsconfig.json

@@ -8,7 +8,7 @@
         "experimentalDecorators": true,
         "emitDecoratorMetadata": true,
         "declaration": false,
-        "noImplicitAny": false,
+        "noImplicitAny": true,
         "removeComments": true,
         "noLib": false,
         "preserveConstEnums": true,