From b970fb4aba71af548dacfddaeefeb5ffbfc7f64f Mon Sep 17 00:00:00 2001
From: Thomas Truong <ttruong@factset.com>
Date: Tue, 12 Jun 2018 14:18:43 +0100
Subject: [PATCH] feat(zen-observable): add concat method typing

Adding missing method concat as shown here https://github.com/zenparsing/zen-observable.
Concat merges the current observable with additional observables.
---
 types/zen-observable/index.d.ts              | 4 +++-
 types/zen-observable/zen-observable-tests.ts | 8 ++++++++
 2 files changed, 11 insertions(+), 1 deletion(-)

diff --git a/types/zen-observable/index.d.ts b/types/zen-observable/index.d.ts
index bcf02e8f8a..94ca94ccd2 100644
--- a/types/zen-observable/index.d.ts
+++ b/types/zen-observable/index.d.ts
@@ -1,7 +1,8 @@
-// Type definitions for zen-observable 0.5
+// Type definitions for zen-observable 0.8
 // Project: https://github.com/zenparsing/zen-observable
 // Definitions by: Kombu <https://github.com/aicest>
 //                 JounQin <https://github.com/JounQin>
+//                 Thomas <https://github.com/itomtom>
 // Definitions: https://github.com/DefinitelyTyped/DefinitelyTyped
 
 declare global {
@@ -52,6 +53,7 @@ declare class Observable<T> {
     reduce(callback: (previousValue: T, currentValue: T) => T, initialValue?: T): Observable<T>;
     reduce<R>(callback: (previousValue: R, currentValue: T) => R, initialValue?: R): Observable<R>;
     flatMap<R>(callback: (value: T) => ZenObservable.ObservableLike<R>): Observable<R>;
+    concat<R>(...observable: Array<Observable<R>>): Observable<R>;
 
     static from<R>(observable: Observable<R> | ZenObservable.ObservableLike<R> | ArrayLike<R>): Observable<R>;
     static of<R>(...items: R[]): Observable<R>;
diff --git a/types/zen-observable/zen-observable-tests.ts b/types/zen-observable/zen-observable-tests.ts
index b06e7cb512..b1aea6d46a 100644
--- a/types/zen-observable/zen-observable-tests.ts
+++ b/types/zen-observable/zen-observable-tests.ts
@@ -94,6 +94,14 @@ Observable.of(1, 2, 3)
     .flatMap(val => Observable.of(val.toString()))
     .subscribe(val => assert(typeof val === 'string'));
 
+/**
+ * observable.concat
+ */
+
+Observable.of(1, 2, 3)
+.concat(Observable.of(4, 5, 6), Observable.of(7, 8, 9))
+.subscribe(val => assert(typeof val === 'number'));
+
 /**
  * ZenObservable
  */