diff --git a/rx.js/rx.js.binding.d.ts b/rx.js/rx.js.binding.d.ts
index e2d4bfd98..7f34fcb01 100644
--- a/rx.js/rx.js.binding.d.ts
+++ b/rx.js/rx.js.binding.d.ts
@@ -16,7 +16,7 @@ declare module Rx {
 	}
 
 	interface BehaviorSubject<T> extends ISubject<T> {
-		new (initialValue: T): BehaviorSubject;
+		new (initialValue: T): BehaviorSubject<any>;
 	}
 
 	interface ConnectableObservable<T> extends IObservable<T>{
diff --git a/rx.js/rx.js.d.ts b/rx.js/rx.js.d.ts
index b94679602..dbb7adb5c 100644
--- a/rx.js/rx.js.d.ts
+++ b/rx.js/rx.js.d.ts
@@ -199,7 +199,7 @@ declare module Rx {
 	interface INotification<T> {
 		accept(observer: IObserver<T>): void;
 		accept(onNext: (value: T) =>void , onError?: (exception: any) =>void , onCompleted?: () =>void ): void;
-		toObservable(scheduler?: IScheduler): IObservable;
+		toObservable(scheduler?: IScheduler): IObservable<any>;
 		hasValue: boolean;
 		equals(other: INotification<T>): boolean;
 		kind: string;
@@ -240,7 +240,7 @@ declare module Rx {
 		export interface Enumerable<T> {
 			(getEnumerator: () =>IEnumerator<T>): IEnumerable<T>;
 
-			repeat(value: T, repeatCount?: number): IEnumerable;
+			repeat(value: T, repeatCount?: number): IEnumerable<any>;
 			forEach<T2>(source: T[], selector?: (element: T, index: number) => T2): IEnumerable<T2>;
 			forEach<T2>(source: { length: number; [index: number]: T; }, selector?: (element: T, index: number) => T2): IEnumerable<T2>;
 		}
@@ -254,7 +254,7 @@ declare module Rx {
 
 		toNotifier(): (notification: INotification<T>) =>void;
 		asObserver(): IObserver<T>;
-		checked(): ICheckedObserver;
+		checked(): ICheckedObserver<any>;
 	}
 	export module Observer {
 		//abstract
@@ -332,7 +332,7 @@ declare module Rx {
 		//concatIObservable(): IObservable<T>;
 		merge(maxConcurrent: number): IObservable<T>;
 		merge(other: IObservable<T>): IObservable<T>;
-		//mergeIObservable(): IObservable;
+		//mergeIObservable(): IObservable<any>;
 		onErrorResumeNext(second: IObservable<T>): IObservable<T>;
 		skipUntil<T2>(other: IObservable<T2>): IObservable<T>;
 		switchLatest(): IObservable<T>;
@@ -343,10 +343,10 @@ declare module Rx {
 		zip<T2, T3, T4, T5, TResult>(second: IObservable<T2>, third: IObservable<T3>, fourth: IObservable<T4>, fifth: IObservable<T5>, resultSelector: (v1: T, v2: T2, v3: T3, v4: T4, v5: T5) => TResult): IObservable<TResult>;
 		zip<TResult>(...soucesAndResultSelector: any[]): IObservable<TResult>;
 		zip<TResult>(second: any[], resultSelector: (left: T, right: any) => TResult): IObservable<TResult>;
-		asIObservable(): IObservable;
+		asIObservable(): IObservable<any>;
 		bufferWithCount(count: number, skip?: number): IObservable<T>;
 		dematerialize<TOrigin>(): IObservable<TOrigin>;
-		distinctUntilChanged<TValue>(keySelector?: (value: T) => TValue, comparer?: (x: TValue, y: TValue) =>boolean): IObservable;
+		distinctUntilChanged<TValue>(keySelector?: (value: T) => TValue, comparer?: (x: TValue, y: TValue) =>boolean): IObservable<any>;
 		doAction(observer: IObserver<T>): IObservable<T>;
 		doAction(onNext: (value: T) => void , onError?: (exception: any) =>void , onCompleted?: () =>void ): IObservable<T>;
 		finallyAction(action: () =>void): IObservable<T>;
@@ -377,7 +377,7 @@ declare module Rx {
 	}
 
 	interface Observable {
-		(subscribe: (observer: IObserver<any>) =>_IDisposable): IObservable;
+		(subscribe: (observer: IObserver<any>) =>_IDisposable): IObservable<any>;
 
 		start<T>(func: () =>T, scheduler?: IScheduler, context?: any): IObservable<T>;
 		toAsync<T>(func: Function, scheduler?: IScheduler, context?: any): (...arguments: any[]) => IObservable<T>;