mst-effect - npm Package Compare versions

Comparing version 1.2.1 to 1.3.0

dist/cjs/effect/doll-effect.js

@@ -12,4 +12,4 @@ "use strict";
     const effect$ = factory(payloadSource.asObservable(), (value) => signalSource.next(value));
-    const subscription = utils_1.subscribe(self, factory, effect$);
-    mobx_state_tree_1.addDisposer(self, () => {
+    const subscription = (0, utils_1.subscribe)(self, factory, effect$);
+    (0, mobx_state_tree_1.addDisposer)(self, () => {
         payloadSource.complete();
@@ -20,6 +20,4 @@ signalSource.complete();
     return (payload, handler) => {
-        const promise = (typeof handler === 'function'
-            ? handler(signalSource.asObservable())
-            : signalSource)
-            .pipe(operators_1.take(1))
+        const promise = (typeof handler === 'function' ? handler(signalSource.asObservable()) : signalSource)
+            .pipe((0, operators_1.take)(1))
             .toPromise();
@@ -26,0 +24,0 @@ payloadSource.next(payload);

dist/cjs/effect/effect.js

@@ -10,4 +10,4 @@ "use strict";
     const effect$ = factory(payloadSource.asObservable());
-    const subscription = utils_1.subscribe(self, factory, effect$);
-    mobx_state_tree_1.addDisposer(self, () => {
+    const subscription = (0, utils_1.subscribe)(self, factory, effect$);
+    (0, mobx_state_tree_1.addDisposer)(self, () => {
         payloadSource.complete();
@@ -14,0 +14,0 @@ subscription.unsubscribe();

dist/cjs/effect/index.js

@@ -5,6 +5,6 @@ "use strict";
 const tslib_1 = require("tslib");
-tslib_1.__exportStar(require("./effect"), exports);
-tslib_1.__exportStar(require("./doll-effect"), exports);
+(0, tslib_1.__exportStar)(require("./effect"), exports);
+(0, tslib_1.__exportStar)(require("./doll-effect"), exports);
 var action_1 = require("./action");
 Object.defineProperty(exports, "action", { enumerable: true, get: function () { return action_1.action; } });
 Object.defineProperty(exports, "NOOP", { enumerable: true, get: function () { return action_1.NOOP; } });

dist/cjs/effect/utils.js

@@ -11,6 +11,6 @@ "use strict";
     return actions$
-        .pipe(operators_1.tap((actions) => { var _a; return (_a = self[const_1.EFFECT_ACTIONS_HANDLER]) === null || _a === void 0 ? void 0 : _a.call(self, actions); }), logAngIgnoreError(factory))
+        .pipe((0, operators_1.tap)((actions) => { var _a; return (_a = self[const_1.EFFECT_ACTIONS_HANDLER]) === null || _a === void 0 ? void 0 : _a.call(self, actions); }), logAngIgnoreError(factory))
         .subscribe();
     function logAngIgnoreError(factory) {
-        return operators_1.catchError((err, caught) => {
+        return (0, operators_1.catchError)((err, caught) => {
             /* eslint-disable no-console */
@@ -17,0 +17,0 @@ console.group('[mst-effect]: error');

dist/cjs/index.js

 "use strict";
 Object.defineProperty(exports, "__esModule", { value: true });
 const tslib_1 = require("tslib");
-tslib_1.__exportStar(require("./mst"), exports);
-tslib_1.__exportStar(require("./types"), exports);
-tslib_1.__exportStar(require("./effect"), exports);
-tslib_1.__exportStar(require("./signal"), exports);
-tslib_1.__exportStar(require("./reaction$"), exports);
+(0, tslib_1.__exportStar)(require("./mst"), exports);
+(0, tslib_1.__exportStar)(require("./types"), exports);
+(0, tslib_1.__exportStar)(require("./effect"), exports);
+(0, tslib_1.__exportStar)(require("./signal"), exports);
+(0, tslib_1.__exportStar)(require("./reaction$"), exports);

dist/cjs/mst/index.js

@@ -6,3 +6,3 @@ "use strict";
 const tslib_1 = require("tslib");
-tslib_1.__exportStar(require("./types-override"), exports);
+(0, tslib_1.__exportStar)(require("./types-override"), exports);
 var mobx_state_tree_1 = require("mobx-state-tree");
@@ -9,0 +9,0 @@ Object.defineProperty(exports, "typecheck", { enumerable: true, get: function () { return mobx_state_tree_1.typecheck; } });

dist/cjs/reaction$/index.d.ts

 import { IReactionPublic, IReactionOptions } from 'mobx';
 import { Observable } from 'rxjs';
-export declare function reaction$<T>(expression: (r: IReactionPublic) => T, opts: Omit<IReactionOptions, 'fireImmediately'> & {
-    fireImmediately: true;
-}): Observable<{
+export declare function reaction$<T>(expression: (r: IReactionPublic) => T, opts: IReactionOptions<T, true>): Observable<{
     current: T;
@@ -10,3 +8,3 @@ prev: T | undefined;
 }>;
-export declare function reaction$<T>(expression: (r: IReactionPublic) => T, opts?: IReactionOptions): Observable<{
+export declare function reaction$<T>(expression: (r: IReactionPublic) => T, opts?: IReactionOptions<T, false>): Observable<{
     current: T;
@@ -13,0 +11,0 @@ prev: T;

dist/cjs/reaction$/index.js

@@ -8,3 +8,3 @@ "use strict";
     return new rxjs_1.Observable((observer) => {
-        const dispose = mobx_1.reaction(expression, (current, prev, r) => observer.next({ current, prev, r }), opts);
+        const dispose = (0, mobx_1.reaction)(expression, (current, prev, r) => observer.next({ current, prev, r }), opts);
         return () => dispose();
@@ -11,0 +11,0 @@ });

dist/cjs/signal/index.js

@@ -10,5 +10,5 @@ "use strict";
     const signal$ = (_a = fn === null || fn === void 0 ? void 0 : fn(payloadSource.asObservable())) !== null && _a !== void 0 ? _a : payloadSource.asObservable();
-    mobx_state_tree_1.addDisposer(self, () => payloadSource.complete());
+    (0, mobx_state_tree_1.addDisposer)(self, () => payloadSource.complete());
     return [signal$, (payload) => payloadSource.next(payload)];
 }
 exports.signal = signal;

dist/esm/effect/doll-effect.js

@@ -16,5 +16,3 @@ import { Subject } from 'rxjs';
     return (payload, handler) => {
-        const promise = (typeof handler === 'function'
-            ? handler(signalSource.asObservable())
-            : signalSource)
+        const promise = (typeof handler === 'function' ? handler(signalSource.asObservable()) : signalSource)
             .pipe(take(1))
@@ -21,0 +19,0 @@ .toPromise();

dist/esm/reaction$/index.d.ts

 import { IReactionPublic, IReactionOptions } from 'mobx';
 import { Observable } from 'rxjs';
-export declare function reaction$<T>(expression: (r: IReactionPublic) => T, opts: Omit<IReactionOptions, 'fireImmediately'> & {
-    fireImmediately: true;
-}): Observable<{
+export declare function reaction$<T>(expression: (r: IReactionPublic) => T, opts: IReactionOptions<T, true>): Observable<{
     current: T;
@@ -10,3 +8,3 @@ prev: T | undefined;
 }>;
-export declare function reaction$<T>(expression: (r: IReactionPublic) => T, opts?: IReactionOptions): Observable<{
+export declare function reaction$<T>(expression: (r: IReactionPublic) => T, opts?: IReactionOptions<T, false>): Observable<{
     current: T;
@@ -13,0 +11,0 @@ prev: T;

package.json

 {
   "name": "mst-effect",
-  "version": "1.2.1",
+  "version": "1.3.0",
   "description": "Designed to be used with MobX-State-Tree to create asynchronous actions using RxJS.",
@@ -49,27 +49,27 @@ "license": "MIT",
     "mobx-state-tree": "^5.0.0 || ^4.0.0",
-    "rxjs": "^6.0.0"
+    "rxjs": "^7.0.0 || 6.0.0"
   },
   "devDependencies": {
-    "@types/jest": "^26.0.20",
-    "@typescript-eslint/eslint-plugin": "^4.18.0",
-    "@typescript-eslint/parser": "^4.18.0",
-    "eslint": "^7.22.0",
-    "eslint-config-prettier": "^8.1.0",
-    "eslint-plugin-prettier": "^3.3.1",
-    "eslint-plugin-react": "^7.22.0",
+    "@types/jest": "^27.0.3",
+    "@typescript-eslint/eslint-plugin": "^5.8.0",
+    "@typescript-eslint/parser": "^5.8.0",
+    "eslint": "^8.5.0",
+    "eslint-config-prettier": "^8.3.0",
+    "eslint-plugin-prettier": "^4.0.0",
+    "eslint-plugin-react": "^7.28.0",
     "format-package": "^6.1.0",
-    "husky": "^5.1.3",
-    "jest": "^26.6.3",
-    "lint-staged": "^10.5.4",
-    "mobx": "^6.1.8",
-    "mobx-state-tree": "^5.0.1",
+    "husky": "^7.0.4",
+    "jest": "^27.4.5",
+    "lint-staged": "^12.1.4",
+    "mobx": "^6.3.10",
+    "mobx-state-tree": "^5.1.0",
     "npm-run-all": "^4.1.5",
-    "prettier": "^2.2.1",
-    "rxjs": "^6.6.6",
-    "ts-jest": "^26.5.3",
-    "ts-node": "^9.1.1",
-    "tsd": "^0.14.0",
-    "tslib": "^2.1.0",
-    "typescript": "^4.2.3"
+    "prettier": "^2.5.1",
+    "rxjs": "^7.4.0",
+    "ts-jest": "^27.1.2",
+    "ts-node": "^10.4.0",
+    "tsd": "^0.19.0",
+    "tslib": "^2.3.1",
+    "typescript": "^4.5.4"
   }
 }

src/effect/doll-effect.ts

@@ -44,5 +44,4 @@ import { Subject, Observable } from 'rxjs'
   return (payload: any, handler: any) => {
-    const promise = (typeof handler === 'function'
-      ? handler(signalSource.asObservable())
-      : signalSource
+    const promise = (
+      typeof handler === 'function' ? handler(signalSource.asObservable()) : signalSource
     )
@@ -49,0 +48,0 @@ .pipe(take(1))

src/reaction$/index.ts

@@ -6,3 +6,3 @@ import { reaction, IReactionPublic, IReactionOptions } from 'mobx'
   expression: (r: IReactionPublic) => T,
-  opts: Omit<IReactionOptions, 'fireImmediately'> & { fireImmediately: true },
+  opts: IReactionOptions<T, true>,
 ): Observable<{ current: T; prev: T | undefined; r: IReactionPublic }>
@@ -12,9 +12,9 @@
   expression: (r: IReactionPublic) => T,
-  opts?: IReactionOptions,
+  opts?: IReactionOptions<T, false>,
 ): Observable<{ current: T; prev: T; r: IReactionPublic }>
 
-export function reaction$<T>(
+export function reaction$<T, FireImmediately extends boolean = false>(
   expression: (r: IReactionPublic) => T,
-  opts?: IReactionOptions,
-): Observable<{ current: T; prev: T; r: IReactionPublic }> {
+  opts?: IReactionOptions<T, FireImmediately>,
+): Observable<{ current: T; prev?: T; r: IReactionPublic }> {
   return new Observable((observer) => {
@@ -21,0 +21,0 @@ const dispose = reaction(

No alert changes

Worsened metrics

Total package byte prevSize

101173

decreased by-0.04%

Lines of code

1491

decreased by-0.6%

No dependency changes