fp-ts-rxjs - npm Package Compare versions

Comparing version 0.6.9 to 0.6.10

CHANGELOG.md

@@ -16,2 +16,9 @@ # Changelog
 
+# 0.6.10
+
+- **New Feature**
+  - add `ReaderObservableEither` module, #34 (@waynevanson )
+  - add `StateReaderObservableEither` module, #34 (@waynevanson )
+  - add `MonadObservable4` interface, #34 (@waynevanson )
+
 # 0.6.9
@@ -18,0 +25,0 @@

es6/index.d.ts

@@ -7,2 +7,4 @@ /**
 import * as observableEither from './ObservableEither';
+import * as readerObservableEither from './ReaderObservableEither';
+import * as stateReaderObservableEither from './StateReaderObservableEither';
 export { 
@@ -20,2 +22,10 @@ /**
  */
-observableEither };
+observableEither, 
+/**
+ * @since 0.6.10
+ */
+readerObservableEither, 
+/**
+ * @since 0.6.10
+ */
+stateReaderObservableEither };

es6/index.js

@@ -7,2 +7,4 @@ /**
 import * as observableEither from './ObservableEither';
+import * as readerObservableEither from './ReaderObservableEither';
+import * as stateReaderObservableEither from './StateReaderObservableEither';
 export { 
@@ -20,2 +22,10 @@ /**
  */
-observableEither };
+observableEither, 
+/**
+ * @since 0.6.10
+ */
+readerObservableEither, 
+/**
+ * @since 0.6.10
+ */
+stateReaderObservableEither };

es6/MonadObservable.d.ts

@@ -6,4 +6,4 @@ /**
  */
-import { HKT, Kind, Kind2, Kind3, URIS, URIS2, URIS3 } from 'fp-ts/es6/HKT';
-import { MonadTask, MonadTask1, MonadTask2, MonadTask2C, MonadTask3, MonadTask3C } from 'fp-ts/es6/MonadTask';
+import { HKT, Kind, Kind2, Kind3, Kind4, URIS, URIS2, URIS3, URIS4 } from 'fp-ts/es6/HKT';
+import { MonadTask, MonadTask1, MonadTask2, MonadTask2C, MonadTask3, MonadTask3C, MonadTask4 } from 'fp-ts/es6/MonadTask';
 import { Observable } from 'rxjs';
@@ -41,3 +41,3 @@ /**
 /**
- * @since 2.2.0
+ * @since 0.6.6
  */
@@ -47,1 +47,7 @@ export interface MonadObservable3C<M extends URIS3, E> extends MonadTask3C<M, E> {
 }
+/**
+ * @since 0.6.7
+ */
+export interface MonadObservable4<M extends URIS4> extends MonadTask4<M> {
+    readonly fromObservable: <S, R, E, A>(fa: Observable<A>) => Kind4<M, S, R, E, A>;
+}

es6/Observable.d.ts

@@ -56,3 +56,3 @@ /**
 export declare const observable: Monad1<URI> & Alternative1<URI> & Filterable1<URI> & MonadObservable1<URI>;
-declare const alt: <A>(that: () => Observable<A>) => (fa: Observable<A>) => Observable<A>, ap: <A>(fa: Observable<A>) => <B>(fab: Observable<(a: A) => B>) => Observable<B>, apFirst: <B>(fb: Observable<B>) => <A>(fa: Observable<A>) => Observable<A>, apSecond: <B>(fb: Observable<B>) => <A>(fa: Observable<A>) => Observable<B>, chain: <A, B>(f: (a: A) => Observable<B>) => (ma: Observable<A>) => Observable<B>, chainFirst: <A, B>(f: (a: A) => Observable<B>) => (ma: Observable<A>) => Observable<A>, compact: <A>(fa: Observable<O.Option<A>>) => Observable<A>, filter: {
+declare const alt: <A>(that: import("fp-ts/lib/function").Lazy<Observable<A>>) => (fa: Observable<A>) => Observable<A>, ap: <A>(fa: Observable<A>) => <B>(fab: Observable<(a: A) => B>) => Observable<B>, apFirst: <B>(fb: Observable<B>) => <A>(fa: Observable<A>) => Observable<A>, apSecond: <B>(fb: Observable<B>) => <A>(fa: Observable<A>) => Observable<B>, chain: <A, B>(f: (a: A) => Observable<B>) => (ma: Observable<A>) => Observable<B>, chainFirst: <A, B>(f: (a: A) => Observable<B>) => (ma: Observable<A>) => Observable<A>, compact: <A>(fa: Observable<O.Option<A>>) => Observable<A>, filter: {
     <A, B extends A>(refinement: import("fp-ts/lib/function").Refinement<A, B>): (fa: Observable<A>) => Observable<B>;
@@ -59,0 +59,0 @@ <A>(predicate: Predicate<A>): (fa: Observable<A>) => Observable<A>;

es6/ObservableEither.d.ts

@@ -93,3 +93,3 @@ /**
 export declare const observableEither: Monad2<URI> & Bifunctor2<URI> & Alt2<URI> & MonadObservable2<URI> & MonadThrow2<URI>;
-declare const alt: <E, A>(that: () => ObservableEither<E, A>) => (fa: ObservableEither<E, A>) => ObservableEither<E, A>, ap: <E, A>(fa: ObservableEither<E, A>) => <B>(fab: ObservableEither<E, (a: A) => B>) => ObservableEither<E, B>, apFirst: <E, B>(fb: ObservableEither<E, B>) => <A>(fa: ObservableEither<E, A>) => ObservableEither<E, A>, apSecond: <E, B>(fb: ObservableEither<E, B>) => <A>(fa: ObservableEither<E, A>) => ObservableEither<E, B>, bimap: <E, G, A, B>(f: (e: E) => G, g: (a: A) => B) => (fa: ObservableEither<E, A>) => ObservableEither<G, B>, chain: <E, A, B>(f: (a: A) => ObservableEither<E, B>) => (ma: ObservableEither<E, A>) => ObservableEither<E, B>, chainFirst: <E, A, B>(f: (a: A) => ObservableEither<E, B>) => (ma: ObservableEither<E, A>) => ObservableEither<E, A>, flatten: <E, A>(mma: ObservableEither<E, ObservableEither<E, A>>) => ObservableEither<E, A>, map: <A, B>(f: (a: A) => B) => <E>(fa: ObservableEither<E, A>) => ObservableEither<E, B>, mapLeft: <E, G>(f: (e: E) => G) => <A>(fa: ObservableEither<E, A>) => ObservableEither<G, A>;
+declare const alt: <E, A>(that: import("fp-ts/lib/function").Lazy<ObservableEither<E, A>>) => (fa: ObservableEither<E, A>) => ObservableEither<E, A>, ap: <E, A>(fa: ObservableEither<E, A>) => <B>(fab: ObservableEither<E, (a: A) => B>) => ObservableEither<E, B>, apFirst: <E, B>(fb: ObservableEither<E, B>) => <A>(fa: ObservableEither<E, A>) => ObservableEither<E, A>, apSecond: <E, B>(fb: ObservableEither<E, B>) => <A>(fa: ObservableEither<E, A>) => ObservableEither<E, B>, bimap: <E, G, A, B>(f: (e: E) => G, g: (a: A) => B) => (fa: ObservableEither<E, A>) => ObservableEither<G, B>, chain: <E, A, B>(f: (a: A) => ObservableEither<E, B>) => (ma: ObservableEither<E, A>) => ObservableEither<E, B>, chainFirst: <E, A, B>(f: (a: A) => ObservableEither<E, B>) => (ma: ObservableEither<E, A>) => ObservableEither<E, A>, flatten: <E, A>(mma: ObservableEither<E, ObservableEither<E, A>>) => ObservableEither<E, A>, map: <A, B>(f: (a: A) => B) => <E>(fa: ObservableEither<E, A>) => ObservableEither<E, B>, mapLeft: <E, G>(f: (e: E) => G) => <A>(fa: ObservableEither<E, A>) => ObservableEither<G, A>;
 export { 
@@ -96,0 +96,0 @@ /**

es6/ReaderObservable.d.ts

@@ -108,3 +108,3 @@ /**
 export declare const readerObservable: Monad2<URI> & Alternative2<URI> & Filterable2<URI> & MonadObservable2<URI>;
-declare const ap: <E, A>(fa: ReaderObservable<E, A>) => <B>(fab: ReaderObservable<E, (a: A) => B>) => ReaderObservable<E, B>, apFirst: <E, B>(fb: ReaderObservable<E, B>) => <A>(fa: ReaderObservable<E, A>) => ReaderObservable<E, A>, apSecond: <E, B>(fb: ReaderObservable<E, B>) => <A>(fa: ReaderObservable<E, A>) => ReaderObservable<E, B>, chain: <E, A, B>(f: (a: A) => ReaderObservable<E, B>) => (ma: ReaderObservable<E, A>) => ReaderObservable<E, B>, chainFirst: <E, A, B>(f: (a: A) => ReaderObservable<E, B>) => (ma: ReaderObservable<E, A>) => ReaderObservable<E, A>, flatten: <E, A>(mma: ReaderObservable<E, ReaderObservable<E, A>>) => ReaderObservable<E, A>, map: <A, B>(f: (a: A) => B) => <E>(fa: ReaderObservable<E, A>) => ReaderObservable<E, B>, alt: <E, A>(that: () => ReaderObservable<E, A>) => (fa: ReaderObservable<E, A>) => ReaderObservable<E, A>, compact: <E, A>(fa: ReaderObservable<E, O.Option<A>>) => ReaderObservable<E, A>, filter: {
+declare const ap: <E, A>(fa: ReaderObservable<E, A>) => <B>(fab: ReaderObservable<E, (a: A) => B>) => ReaderObservable<E, B>, apFirst: <E, B>(fb: ReaderObservable<E, B>) => <A>(fa: ReaderObservable<E, A>) => ReaderObservable<E, A>, apSecond: <E, B>(fb: ReaderObservable<E, B>) => <A>(fa: ReaderObservable<E, A>) => ReaderObservable<E, B>, chain: <E, A, B>(f: (a: A) => ReaderObservable<E, B>) => (ma: ReaderObservable<E, A>) => ReaderObservable<E, B>, chainFirst: <E, A, B>(f: (a: A) => ReaderObservable<E, B>) => (ma: ReaderObservable<E, A>) => ReaderObservable<E, A>, flatten: <E, A>(mma: ReaderObservable<E, ReaderObservable<E, A>>) => ReaderObservable<E, A>, map: <A, B>(f: (a: A) => B) => <E>(fa: ReaderObservable<E, A>) => ReaderObservable<E, B>, alt: <E, A>(that: import("fp-ts/lib/function").Lazy<ReaderObservable<E, A>>) => (fa: ReaderObservable<E, A>) => ReaderObservable<E, A>, compact: <E, A>(fa: ReaderObservable<E, O.Option<A>>) => ReaderObservable<E, A>, filter: {
     <A, B extends A>(refinement: import("fp-ts/lib/function").Refinement<A, B>): <E>(fa: ReaderObservable<E, A>) => ReaderObservable<E, B>;
@@ -111,0 +111,0 @@ <A>(predicate: Predicate<A>): <E>(fa: ReaderObservable<E, A>) => ReaderObservable<E, A>;

lib/index.d.ts

@@ -7,2 +7,4 @@ /**
 import * as observableEither from './ObservableEither';
+import * as readerObservableEither from './ReaderObservableEither';
+import * as stateReaderObservableEither from './StateReaderObservableEither';
 export { 
@@ -20,2 +22,10 @@ /**
  */
-observableEither };
+observableEither, 
+/**
+ * @since 0.6.10
+ */
+readerObservableEither, 
+/**
+ * @since 0.6.10
+ */
+stateReaderObservableEither };

lib/index.js

@@ -12,1 +12,5 @@ "use strict";
 exports.observableEither = observableEither;
+var readerObservableEither = require("./ReaderObservableEither");
+exports.readerObservableEither = readerObservableEither;
+var stateReaderObservableEither = require("./StateReaderObservableEither");
+exports.stateReaderObservableEither = stateReaderObservableEither;

lib/MonadObservable.d.ts

@@ -6,4 +6,4 @@ /**
  */
-import { HKT, Kind, Kind2, Kind3, URIS, URIS2, URIS3 } from 'fp-ts/lib/HKT';
-import { MonadTask, MonadTask1, MonadTask2, MonadTask2C, MonadTask3, MonadTask3C } from 'fp-ts/lib/MonadTask';
+import { HKT, Kind, Kind2, Kind3, Kind4, URIS, URIS2, URIS3, URIS4 } from 'fp-ts/lib/HKT';
+import { MonadTask, MonadTask1, MonadTask2, MonadTask2C, MonadTask3, MonadTask3C, MonadTask4 } from 'fp-ts/lib/MonadTask';
 import { Observable } from 'rxjs';
@@ -41,3 +41,3 @@ /**
 /**
- * @since 2.2.0
+ * @since 0.6.6
  */
@@ -47,1 +47,7 @@ export interface MonadObservable3C<M extends URIS3, E> extends MonadTask3C<M, E> {
 }
+/**
+ * @since 0.6.7
+ */
+export interface MonadObservable4<M extends URIS4> extends MonadTask4<M> {
+    readonly fromObservable: <S, R, E, A>(fa: Observable<A>) => Kind4<M, S, R, E, A>;
+}

lib/Observable.d.ts

@@ -56,3 +56,3 @@ /**
 export declare const observable: Monad1<URI> & Alternative1<URI> & Filterable1<URI> & MonadObservable1<URI>;
-declare const alt: <A>(that: () => Observable<A>) => (fa: Observable<A>) => Observable<A>, ap: <A>(fa: Observable<A>) => <B>(fab: Observable<(a: A) => B>) => Observable<B>, apFirst: <B>(fb: Observable<B>) => <A>(fa: Observable<A>) => Observable<A>, apSecond: <B>(fb: Observable<B>) => <A>(fa: Observable<A>) => Observable<B>, chain: <A, B>(f: (a: A) => Observable<B>) => (ma: Observable<A>) => Observable<B>, chainFirst: <A, B>(f: (a: A) => Observable<B>) => (ma: Observable<A>) => Observable<A>, compact: <A>(fa: Observable<O.Option<A>>) => Observable<A>, filter: {
+declare const alt: <A>(that: import("fp-ts/lib/function").Lazy<Observable<A>>) => (fa: Observable<A>) => Observable<A>, ap: <A>(fa: Observable<A>) => <B>(fab: Observable<(a: A) => B>) => Observable<B>, apFirst: <B>(fb: Observable<B>) => <A>(fa: Observable<A>) => Observable<A>, apSecond: <B>(fb: Observable<B>) => <A>(fa: Observable<A>) => Observable<B>, chain: <A, B>(f: (a: A) => Observable<B>) => (ma: Observable<A>) => Observable<B>, chainFirst: <A, B>(f: (a: A) => Observable<B>) => (ma: Observable<A>) => Observable<A>, compact: <A>(fa: Observable<O.Option<A>>) => Observable<A>, filter: {
     <A, B extends A>(refinement: import("fp-ts/lib/function").Refinement<A, B>): (fa: Observable<A>) => Observable<B>;
@@ -59,0 +59,0 @@ <A>(predicate: Predicate<A>): (fa: Observable<A>) => Observable<A>;

lib/ObservableEither.d.ts

@@ -93,3 +93,3 @@ /**
 export declare const observableEither: Monad2<URI> & Bifunctor2<URI> & Alt2<URI> & MonadObservable2<URI> & MonadThrow2<URI>;
-declare const alt: <E, A>(that: () => ObservableEither<E, A>) => (fa: ObservableEither<E, A>) => ObservableEither<E, A>, ap: <E, A>(fa: ObservableEither<E, A>) => <B>(fab: ObservableEither<E, (a: A) => B>) => ObservableEither<E, B>, apFirst: <E, B>(fb: ObservableEither<E, B>) => <A>(fa: ObservableEither<E, A>) => ObservableEither<E, A>, apSecond: <E, B>(fb: ObservableEither<E, B>) => <A>(fa: ObservableEither<E, A>) => ObservableEither<E, B>, bimap: <E, G, A, B>(f: (e: E) => G, g: (a: A) => B) => (fa: ObservableEither<E, A>) => ObservableEither<G, B>, chain: <E, A, B>(f: (a: A) => ObservableEither<E, B>) => (ma: ObservableEither<E, A>) => ObservableEither<E, B>, chainFirst: <E, A, B>(f: (a: A) => ObservableEither<E, B>) => (ma: ObservableEither<E, A>) => ObservableEither<E, A>, flatten: <E, A>(mma: ObservableEither<E, ObservableEither<E, A>>) => ObservableEither<E, A>, map: <A, B>(f: (a: A) => B) => <E>(fa: ObservableEither<E, A>) => ObservableEither<E, B>, mapLeft: <E, G>(f: (e: E) => G) => <A>(fa: ObservableEither<E, A>) => ObservableEither<G, A>;
+declare const alt: <E, A>(that: import("fp-ts/lib/function").Lazy<ObservableEither<E, A>>) => (fa: ObservableEither<E, A>) => ObservableEither<E, A>, ap: <E, A>(fa: ObservableEither<E, A>) => <B>(fab: ObservableEither<E, (a: A) => B>) => ObservableEither<E, B>, apFirst: <E, B>(fb: ObservableEither<E, B>) => <A>(fa: ObservableEither<E, A>) => ObservableEither<E, A>, apSecond: <E, B>(fb: ObservableEither<E, B>) => <A>(fa: ObservableEither<E, A>) => ObservableEither<E, B>, bimap: <E, G, A, B>(f: (e: E) => G, g: (a: A) => B) => (fa: ObservableEither<E, A>) => ObservableEither<G, B>, chain: <E, A, B>(f: (a: A) => ObservableEither<E, B>) => (ma: ObservableEither<E, A>) => ObservableEither<E, B>, chainFirst: <E, A, B>(f: (a: A) => ObservableEither<E, B>) => (ma: ObservableEither<E, A>) => ObservableEither<E, A>, flatten: <E, A>(mma: ObservableEither<E, ObservableEither<E, A>>) => ObservableEither<E, A>, map: <A, B>(f: (a: A) => B) => <E>(fa: ObservableEither<E, A>) => ObservableEither<E, B>, mapLeft: <E, G>(f: (e: E) => G) => <A>(fa: ObservableEither<E, A>) => ObservableEither<G, A>;
 export { 
@@ -96,0 +96,0 @@ /**

lib/ReaderObservable.d.ts

@@ -108,3 +108,3 @@ /**
 export declare const readerObservable: Monad2<URI> & Alternative2<URI> & Filterable2<URI> & MonadObservable2<URI>;
-declare const ap: <E, A>(fa: ReaderObservable<E, A>) => <B>(fab: ReaderObservable<E, (a: A) => B>) => ReaderObservable<E, B>, apFirst: <E, B>(fb: ReaderObservable<E, B>) => <A>(fa: ReaderObservable<E, A>) => ReaderObservable<E, A>, apSecond: <E, B>(fb: ReaderObservable<E, B>) => <A>(fa: ReaderObservable<E, A>) => ReaderObservable<E, B>, chain: <E, A, B>(f: (a: A) => ReaderObservable<E, B>) => (ma: ReaderObservable<E, A>) => ReaderObservable<E, B>, chainFirst: <E, A, B>(f: (a: A) => ReaderObservable<E, B>) => (ma: ReaderObservable<E, A>) => ReaderObservable<E, A>, flatten: <E, A>(mma: ReaderObservable<E, ReaderObservable<E, A>>) => ReaderObservable<E, A>, map: <A, B>(f: (a: A) => B) => <E>(fa: ReaderObservable<E, A>) => ReaderObservable<E, B>, alt: <E, A>(that: () => ReaderObservable<E, A>) => (fa: ReaderObservable<E, A>) => ReaderObservable<E, A>, compact: <E, A>(fa: ReaderObservable<E, O.Option<A>>) => ReaderObservable<E, A>, filter: {
+declare const ap: <E, A>(fa: ReaderObservable<E, A>) => <B>(fab: ReaderObservable<E, (a: A) => B>) => ReaderObservable<E, B>, apFirst: <E, B>(fb: ReaderObservable<E, B>) => <A>(fa: ReaderObservable<E, A>) => ReaderObservable<E, A>, apSecond: <E, B>(fb: ReaderObservable<E, B>) => <A>(fa: ReaderObservable<E, A>) => ReaderObservable<E, B>, chain: <E, A, B>(f: (a: A) => ReaderObservable<E, B>) => (ma: ReaderObservable<E, A>) => ReaderObservable<E, B>, chainFirst: <E, A, B>(f: (a: A) => ReaderObservable<E, B>) => (ma: ReaderObservable<E, A>) => ReaderObservable<E, A>, flatten: <E, A>(mma: ReaderObservable<E, ReaderObservable<E, A>>) => ReaderObservable<E, A>, map: <A, B>(f: (a: A) => B) => <E>(fa: ReaderObservable<E, A>) => ReaderObservable<E, B>, alt: <E, A>(that: import("fp-ts/lib/function").Lazy<ReaderObservable<E, A>>) => (fa: ReaderObservable<E, A>) => ReaderObservable<E, A>, compact: <E, A>(fa: ReaderObservable<E, O.Option<A>>) => ReaderObservable<E, A>, filter: {
     <A, B extends A>(refinement: import("fp-ts/lib/function").Refinement<A, B>): <E>(fa: ReaderObservable<E, A>) => ReaderObservable<E, B>;
@@ -111,0 +111,0 @@ <A>(predicate: Predicate<A>): <E>(fa: ReaderObservable<E, A>) => ReaderObservable<E, A>;

package.json

 {
   "name": "fp-ts-rxjs",
-  "version": "0.6.9",
+  "version": "0.6.10",
   "description": "fp-ts bindings for RxJS",
@@ -37,3 +37,3 @@ "files": [
   "peerDependencies": {
-    "fp-ts": "^2.4.3",
+    "fp-ts": "^2.4.4",
     "rxjs": "^6.0.0"
@@ -45,3 +45,3 @@ },
     "docs-ts": "^0.3.4",
-    "fp-ts": "^2.4.3",
+    "fp-ts": "^2.4.4",
     "import-path-rewrite": "github:gcanti/import-path-rewrite",
@@ -48,0 +48,0 @@ "jest": "^24.8.0",

New alerts

License Policy Violation

License

This package is not allowed per your license policy. Review the package's license to ensure compliance.

Found 1 instance in 1 package

Fixed alerts

License Policy Violation

License

This package is not allowed per your license policy. Review the package's license to ensure compliance.

Found 1 instance in 1 package

Improved metrics

Total package byte prevSize

94445

increased by54.58%

Number of package files

32

increased by33.33%

Lines of code

3137

increased by58.84%

No dependency changes