version 0.6.7

CHANGELOG.md

@@ -13,6 +13,12 @@
 **Note**: Gaps between patch versions are faulty/broken releases. **Note**: A feature tagged as Experimental is in a
 high state of flux, you're at risk of it changing without notice.
 
+# 0.6.7
+
+- **New Feature**
+  - `ReaderObservable`
+    - add `Alternative` and `Filterable` instances (@mlegenhausen)
+
 # 0.6.6
 
 - **New Feature**

package.json

@@ -1,6 +1,6 @@
 {
   "name": "fp-ts-rxjs",
-  "version": "0.6.6",
+  "version": "0.6.7",
   "description": "fp-ts bindings for RxJS",
   "files": [
     "lib",

src/Observable.ts

@@ -90,18 +90,8 @@ export const observable: Monad1<URI> & Alternative1<URI> & Filterable1<URI> & Mo
   compact: fa => observable.filterMap(fa, identity),
   separate: fa => observable.partitionMap(fa, identity),
   partitionMap: (fa, f) => ({
-    left: observable.filterMap(fa, a =>
-      pipe(
-        f(a),
-        E.fold(O.some, () => O.none)
-      )
-    ),
-    right: observable.filterMap(fa, a =>
-      pipe(
-        f(a),
-        E.fold(() => O.none, O.some)
-      )
-    )
+    left: observable.filterMap(fa, a => O.fromEither(E.swap(f(a)))),
+    right: observable.filterMap(fa, a => O.fromEither(f(a)))
   }),
   partition: <A>(fa: Observable<A>, p: Predicate<A>) => observable.partitionMap(fa, E.fromPredicate(p, identity)),
   filterMap: <A, B>(fa: Observable<A>, f: (a: A) => O.Option<B>) =>

src/ReaderObservable.ts

@@ -4,7 +4,7 @@
 import { Observable } from 'rxjs'
 import { getReaderM } from 'fp-ts/lib/ReaderT'
 import * as R from './Observable'
-import { pipeable, pipe } from 'fp-ts/lib/pipeable'
+import { pipeable } from 'fp-ts/lib/pipeable'
 import { IO } from 'fp-ts/lib/IO'
 import { Monad2 } from 'fp-ts/lib/Monad'
 import { Monoid } from 'fp-ts/lib/Monoid'
@@ -164,18 +164,8 @@ export const readerObservable: Monad2<URI> & Alternative2<URI> & Filterable2<URI
   compact: fa => readerObservable.filterMap(fa, identity),
   separate: fa => readerObservable.partitionMap(fa, identity),
   partitionMap: (fa, f) => ({
-    left: readerObservable.filterMap(fa, a =>
-      pipe(
-        f(a),
-        E.fold(O.some, () => O.none)
-      )
-    ),
-    right: readerObservable.filterMap(fa, a =>
-      pipe(
-        f(a),
-        E.fold(() => O.none, O.some)
-      )
-    )
+    left: readerObservable.filterMap(fa, a => O.fromEither(E.swap(f(a)))),
+    right: readerObservable.filterMap(fa, a => O.fromEither(f(a)))
   }),
   partition: <R, A>(fa: ReaderObservable<R, A>, p: Predicate<A>) =>
     readerObservable.partitionMap(fa, E.fromPredicate(p, identity)),