From e56c6d9aaa0daf4164216daa7dd413fe1ef89b33 Mon Sep 17 00:00:00 2001
From: Igor Oleinikov <igor@oleinikov.ru>
Date: Tue, 7 Oct 2014 11:19:10 -0700
Subject: [PATCH] Added helpers.isFunction; added thisArg to
 Observer.fromNotifier; added Observable.subscribeOn*.

---
 rx-lite.d.ts | 7 ++++++-
 1 file changed, 6 insertions(+), 1 deletion(-)

diff --git a/rx-lite.d.ts b/rx-lite.d.ts
index 68273c2fb..78b0c5a8c 100644
--- a/rx-lite.d.ts
+++ b/rx-lite.d.ts
@@ -60,6 +60,7 @@ declare module Rx {
 		function isPromise(p: any): boolean;
 		function asArray<T>(...args: T[]): T[];
 		function not(value: any): boolean;
+		function isFunction(value: any): boolean;
 	}
 
 	export interface IDisposable {
@@ -180,7 +181,7 @@ declare module Rx {
 
 	interface ObserverStatic {
 		create<T>(onNext?: (value: T) => void, onError?: (exception: any) => void, onCompleted?: () => void): Observer<T>;
-		fromNotifier<T>(handler: (notification: Notification<T>) => void): Observer<T>;
+		fromNotifier<T>(handler: (notification: Notification<T>, thisArg?: any) => void): Observer<T>;
 	}
 
 	export var Observer: ObserverStatic;
@@ -188,6 +189,10 @@ declare module Rx {
 	export interface IObservable<T> {
 		subscribe(observer: Observer<T>): IDisposable;
 		subscribe(onNext?: (value: T) => void, onError?: (exception: any) => void, onCompleted?: () => void): IDisposable;
+
+		subscribeOnNext(onNext: (value: T) => void, thisArg?: any): IDisposable;
+		subscribeOnError(onError: (exception: any) => void, thisArg?: any): IDisposable;
+		subscribeOnCompleted(onCompleted: () => void, thisArg?: any): IDisposable;
 	}
 
 	export interface Observable<T> extends IObservable<T> {