Merge pull request #228 from tusharmath/feat-combine

Feat combine

Author: tusharmath

API.md

@@ -21,6 +21,7 @@
   - [fromNodeStream](#fromNodeStream)
 
 - [Operators](#operators)
+  - [combine](#combine)
   - [concat](#concat)
   - [concatMap](#concatMap)
   - [delay](#delay)
@@ -430,6 +431,13 @@ function concatMap(fn : (i: any) => Observable, source: Observable): Observable
 ```
 Its a special case for [mergeMap](#mergeMap) where the `concurrency` is set to `one`. This ensures unless the previous subscriptions end new ones are not created.
 
+## combine
+```ts
+function combine(a: Selector, s: Observable[]): Observable
+```
+Combines multiple streams into one using a selector.
+
+
 ## concat
 ```ts
 function concat(a: Observable, b: Observable): Observable

src/main.ts

@@ -2,6 +2,7 @@
  * Created by tushar on 17/02/17.
  */
 
+export {combine} from './operators/Combine'
 export {concatMap} from './operators/MergeMap'
 export {concat} from './operators/Concat'
 export {delay} from './operators/Delay'

src/operators/Reduce.ts

@@ -63,11 +63,11 @@ export const reduce = curry(function<T, R>(
     (seed: TSeed<R>, source: TSource<T>): TResult<R>
   }
 } & {
-    <T, R>(reducer: TReducer<T, R>, seed: TSeed<R>): {
-      (source: TSource<T>): TResult<R>
-    }
-  } & {
-    <T, R>(reducer: TReducer<T, R>): {
-      (seed: TSeed<R>): {(source: TSource<T>): TResult<R>}
-    }
+  <T, R>(reducer: TReducer<T, R>, seed: TSeed<R>): {
+    (source: TSource<T>): TResult<R>
   }
+} & {
+  <T, R>(reducer: TReducer<T, R>): {
+    (seed: TSeed<R>): {(source: TSource<T>): TResult<R>}
+  }
+}

src/operators/Sample.ts

@@ -106,11 +106,11 @@ export const sample = curry(function<T>(
     (sampler: TSampler, source: TSources): TResult<T>
   }
 } & {
-    <T>(selector: TSelector<T>, sampler: TSampler): {
-      (source: TSources): TResult<T>
-    }
-  } & {
-    <T>(selector: TSelector<T>): {
-      (sampler: TSampler): {(source: TSources): TResult<T>}
-    }
+  <T>(selector: TSelector<T>, sampler: TSampler): {
+    (source: TSources): TResult<T>
+  }
+} & {
+  <T>(selector: TSelector<T>): {
+    (sampler: TSampler): {(source: TSources): TResult<T>}
   }
+}

src/operators/Scan.ts

@@ -59,11 +59,11 @@ export const scan = curry(function<T, V>(
     (seed: TSeed<R>, source: TSource<T>): TResult<R>
   }
 } & {
-    <T, R>(reducer: TReducer<T, R>, seed: TSeed<R>): {
-      (source: TSource<T>): TResult<R>
-    }
-  } & {
-    <T, R>(reducer: TReducer<T, R>): {
-      (seed: TSeed<R>): {(source: TSource<T>): TResult<R>}
-    }
+  <T, R>(reducer: TReducer<T, R>, seed: TSeed<R>): {
+    (source: TSource<T>): TResult<R>
   }
+} & {
+  <T, R>(reducer: TReducer<T, R>): {
+    (seed: TSeed<R>): {(source: TSource<T>): TResult<R>}
+  }
+}

src/operators/Slice.ts

@@ -77,11 +77,11 @@ export const slice = curry(function(
 } & {
   <T>(start: number): {(count: number, source: IObservable<T>): IObservable<T>}
 } & {
-    <T>(start: number, count: number): {
-      (source: IObservable<T>): IObservable<T>
-    }
-  } & {
-    <T>(start: number): {
-      (count: number): {(source: IObservable<T>): IObservable<T>}
-    }
+  <T>(start: number, count: number): {
+    (source: IObservable<T>): IObservable<T>
   }
+} & {
+  <T>(start: number): {
+    (count: number): {(source: IObservable<T>): IObservable<T>}
+  }
+}