From c4d63af4ec126eaa52d191b4914c65250a027a50 Mon Sep 17 00:00:00 2001
From: Thomas-P <tp@tp-software.eu>
Date: Tue, 28 Jun 2016 13:42:30 +0200
Subject: [PATCH] Fixing return values for Observable functions

All Observable functions return an Observable<T> instead of T. So I
fixed this in the rx-lite.d.ts
---
 rx/rx-lite-tests.ts | 33 +++++++++++++++++++++++++++++++++
 rx/rx-lite.d.ts     | 12 ++++++------
 2 files changed, 39 insertions(+), 6 deletions(-)

diff --git a/rx/rx-lite-tests.ts b/rx/rx-lite-tests.ts
index 9949fa2ea8..a6adbdc289 100644
--- a/rx/rx-lite-tests.ts
+++ b/rx/rx-lite-tests.ts
@@ -9,5 +9,38 @@ function test_scan() {
 	const source2: Rx.Observable<string> = Rx.Observable.range(1, 3)
 		.scan((acc, x, i, source) => acc + x, '...');
 
+
+	/* concatAll Example */
+	var source = Rx.Observable.range(0, 3)
+		.map(function (x) { return Rx.Observable.range(x, 3); })
+		.concatAll();
+
+	var subscription = source.subscribe(
+		function (x) {
+			console.log('Next: %s', x);
+		},
+		function (err) {
+			console.log('Error: %s', err);
+		},
+		function () {
+			console.log('Completed');
+		});
+
+	/* mergeAll example */
+	var source = Rx.Observable.range(0, 3)
+		.map(function (x) { return Rx.Observable.range(x, 3); })
+		.mergeAll();
+
+	var subscription = source.subscribe(
+		function (x) {
+			console.log('Next: %s', x);
+		},
+		function (err) {
+			console.log('Error: %s', err);
+		},
+		function () {
+			console.log('Completed');
+		});
+
 }
 
diff --git a/rx/rx-lite.d.ts b/rx/rx-lite.d.ts
index aa8137f7b7..f159979204 100644
--- a/rx/rx-lite.d.ts
+++ b/rx/rx-lite.d.ts
@@ -245,8 +245,8 @@ declare namespace Rx {
 		withLatestFrom<TOther, TResult>(souces: (Observable<TOther>|IPromise<TOther>)[], resultSelector: (firstValue: T, ...otherValues: TOther[]) => TResult): Observable<TResult>;
 		concat(...sources: (Observable<T>|IPromise<T>)[]): Observable<T>;
 		concat(sources: (Observable<T>|IPromise<T>)[]): Observable<T>;
-		concatAll(): T;
-		concatObservable(): T;	// alias for concatAll
+		concatAll(): Observable<T>;
+		concatObservable(): Observable<T>;	// alias for concatAll
 		concatMap<T2, R>(selector: (value: T, index: number) => Observable<T2>, resultSelector: (value1: T, value2: T2, index: number) => R): Observable<R>;	// alias for selectConcat
 		concatMap<T2, R>(selector: (value: T, index: number) => IPromise<T2>, resultSelector: (value1: T, value2: T2, index: number) => R): Observable<R>;	// alias for selectConcat
 		concatMap<R>(selector: (value: T, index: number) => Observable<R>): Observable<R>;	// alias for selectConcat
@@ -257,12 +257,12 @@ declare namespace Rx {
 		merge(maxConcurrent: number): T;
 		merge(other: Observable<T>): Observable<T>;
 		merge(other: IPromise<T>): Observable<T>;
-		mergeAll(): T;
-		mergeObservable(): T;	// alias for mergeAll
+		mergeAll(): Observable<T>;
+		mergeObservable(): Observable<T>;	// alias for mergeAll
 		skipUntil<T2>(other: Observable<T2>): Observable<T>;
 		skipUntil<T2>(other: IPromise<T2>): Observable<T>;
-		switch(): T;
-		switchLatest(): T;	// alias for switch
+		switch(): Observable<T>;
+		switchLatest(): Observable<T>;	// alias for switch
 		takeUntil<T2>(other: Observable<T2>): Observable<T>;
 		takeUntil<T2>(other: IPromise<T2>): Observable<T>;
 		zip<T2>(second: Observable<T2>|IPromise<T2>): Observable<[T, T2]>;