Merge pull request #51 from tusharmath/fix-foreach

fix(forEach): fix type signature
tusharmath · Nov 1, 2016 · f19c373 · f19c373
2 parents ad52802 + 239ea9d
commit f19c373
Showing 1 changed file with 3 additions and 4 deletions.
diff --git a/src/lib/ForEach.ts b/src/lib/ForEach.ts
@@ -10,7 +10,6 @@ import {Curry2} from './Curry'
 import {ICurriedFunction2} from '../types/ICurriedFunction'
 import {Observer} from './Observer'
 
-export const forEach = Curry2(function <T> (onNext: {(value: T): void} | IObserver<T>, observable: IObservable<any>) {
-  const observer: IObserver<T> = typeof onNext === 'function' ? Observer.of(onNext) : onNext
-  return observable.subscribe(observer, DefaultScheduler.of())
-}) as ICurriedFunction2<IObservable<any>, IObserver<any>, ISubscription>
+export const forEach = Curry2(function <T> (onNext: {(value: T): void}, observable: IObservable<any>) {
+  return observable.subscribe(Observer.of(onNext), DefaultScheduler.of())
+}) as ICurriedFunction2<{(value: any): void}, IObservable<any>, ISubscription>