diff --git a/src/lib/ForEach.ts b/src/lib/ForEach.ts
index 2b348a8..7f7ad8d 100644
--- 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>