@react-rxjs/utils - npm Package Compare versions

Comparing version 0.9.3 to 0.9.4

dist/utils.cjs.development.js

@@ -1,17 +0,14 @@
-var __create = Object.create;
 var __defProp = Object.defineProperty;
 var __getOwnPropDesc = Object.getOwnPropertyDescriptor;
 var __getOwnPropNames = Object.getOwnPropertyNames;
-var __getProtoOf = Object.getPrototypeOf;
 var __hasOwnProp = Object.prototype.hasOwnProperty;
 var __markAsModule = (target) => __defProp(target, "__esModule", { value: true });
 var __export = (target, all) => {
-  __markAsModule(target);
   for (var name in all)
     __defProp(target, name, { get: all[name], enumerable: true });
 };
-var __reExport = (target, module2, desc) => {
+var __reExport = (target, module2, copyDefault, desc) => {
   if (module2 && typeof module2 === "object" || typeof module2 === "function") {
     for (let key of __getOwnPropNames(module2))
-      if (!__hasOwnProp.call(target, key) && key !== "default")
+      if (!__hasOwnProp.call(target, key) && (copyDefault || key !== "default"))
         __defProp(target, key, { get: () => module2[key], enumerable: !(desc = __getOwnPropDesc(module2, key)) || desc.enumerable });
@@ -21,8 +18,11 @@ }
 };
-var __toModule = (module2) => {
-  return __reExport(__markAsModule(__defProp(module2 != null ? __create(__getProtoOf(module2)) : {}, "default", module2 && module2.__esModule && "default" in module2 ? { get: () => module2.default, enumerable: true } : { value: module2, enumerable: true })), module2);
-};
+var __toCommonJS = /* @__PURE__ */ ((cache) => {
+  return (module2, temp) => {
+    return cache && cache.get(module2) || (temp = __reExport(__markAsModule({}), module2, 1), cache && cache.set(module2, temp), temp);
+  };
+})(typeof WeakMap !== "undefined" ? /* @__PURE__ */ new WeakMap() : 0);
 
 // src/index.tsx
-__export(exports, {
+var src_exports = {};
+__export(src_exports, {
   combineKeys: () => combineKeys,
@@ -42,7 +42,7 @@ contextBinder: () => contextBinder,
 // src/combineKeys.ts
-var import_rxjs = __toModule(require("rxjs"));
+var import_rxjs = require("rxjs");
 var combineKeys = (keys$, getInner$) => new import_rxjs.Observable((observer) => {
-  const innerSubscriptions = new Map();
-  let changes = new Set();
-  const currentValue = new Map();
+  const innerSubscriptions = /* @__PURE__ */ new Map();
+  let changes = /* @__PURE__ */ new Set();
+  const currentValue = /* @__PURE__ */ new Map();
   let updatingSource = false;
@@ -55,3 +55,3 @@ let isPristine = true;
       });
-      changes = new Set();
+      changes = /* @__PURE__ */ new Set();
       isPristine = false;
@@ -104,3 +104,3 @@ observer.next(result);
 // src/createSignal.ts
-var import_rxjs2 = __toModule(require("rxjs"));
+var import_rxjs2 = require("rxjs");
 function createSignal(mapper = import_rxjs2.identity) {
@@ -112,5 +112,5 @@ const subject = new import_rxjs2.Subject();
 // src/createKeyedSignal.ts
-var import_rxjs3 = __toModule(require("rxjs"));
+var import_rxjs3 = require("rxjs");
 function createKeyedSignal(keySelector, mapper) {
-  const observersMap = new Map();
+  const observersMap = /* @__PURE__ */ new Map();
   return [
@@ -120,3 +120,3 @@ (key) => {
         if (!observersMap.has(key)) {
-          observersMap.set(key, new Set());
+          observersMap.set(key, /* @__PURE__ */ new Set());
         }
@@ -147,13 +147,13 @@ const set = observersMap.get(key);
 // src/mergeWithKey.ts
-var import_rxjs4 = __toModule(require("rxjs"));
-var import_operators = __toModule(require("rxjs/operators"));
+var import_rxjs4 = require("rxjs");
+var import_operators = require("rxjs/operators");
 var mergeWithKey = (input, ...optionalArgs) => (0, import_rxjs4.merge)(...Object.entries(input).map(([type, stream]) => (0, import_rxjs4.from)(stream).pipe((0, import_operators.map)((payload) => ({ type, payload })))).concat(optionalArgs));
 
 // src/partitionByKey.ts
-var import_core = __toModule(require("@react-rxjs/core"));
-var import_rxjs5 = __toModule(require("rxjs"));
-var import_operators2 = __toModule(require("rxjs/operators"));
+var import_core = require("@react-rxjs/core");
+var import_rxjs5 = require("rxjs");
+var import_operators2 = require("rxjs/operators");
 function partitionByKey(stream, keySelector, streamSelector) {
   const groupedObservables$ = new import_rxjs5.Observable((subscriber) => {
-    const groups = new Map();
+    const groups = /* @__PURE__ */ new Map();
     let emitted = false;
@@ -239,7 +239,7 @@ let sourceCompleted = false;
 // src/suspend.ts
-var import_rxjs7 = __toModule(require("rxjs"));
-var import_core2 = __toModule(require("@react-rxjs/core"));
+var import_rxjs7 = require("rxjs");
+var import_core2 = require("@react-rxjs/core");
 
 // src/internal-utils.ts
-var import_rxjs6 = __toModule(require("rxjs"));
+var import_rxjs6 = require("rxjs");
 var defaultStart = (value) => (source$) => new import_rxjs6.Observable((observer) => {
@@ -268,9 +268,9 @@ let emitted = false;
 // src/switchMapSuspended.ts
-var import_rxjs8 = __toModule(require("rxjs"));
-var import_operators3 = __toModule(require("rxjs/operators"));
+var import_rxjs8 = require("rxjs");
+var import_operators3 = require("rxjs/operators");
 var switchMapSuspended = (project) => (0, import_rxjs8.pipe)((0, import_operators3.switchMap)((x, index) => suspend(project(x, index))));
 
 // src/selfDependant.ts
-var import_rxjs9 = __toModule(require("rxjs"));
-var import_operators4 = __toModule(require("rxjs/operators"));
+var import_rxjs9 = require("rxjs");
+var import_operators4 = require("rxjs/operators");
 var selfDependant = () => {
@@ -285,3 +285,3 @@ const mirrored$ = new import_rxjs9.Subject();
 // src/contextBinder.ts
-var import_core3 = __toModule(require("@react-rxjs/core"));
+var import_core3 = require("@react-rxjs/core");
 var execSelf = (fn) => fn();
@@ -300,2 +300,3 @@ function contextBinder(...args) {
 }
+module.exports = __toCommonJS(src_exports);
 //# sourceMappingURL=utils.cjs.development.js.map

dist/utils.cjs.production.min.js

@@ -1,2 +0,2 @@
-var H=Object.create;var O=Object.defineProperty;var J=Object.getOwnPropertyDescriptor;var Q=Object.getOwnPropertyNames;var X=Object.getPrototypeOf,Y=Object.prototype.hasOwnProperty;var g=e=>O(e,"__esModule",{value:!0});var Z=(e,s)=>{g(e);for(var r in s)O(e,r,{get:s[r],enumerable:!0})},_=(e,s,r)=>{if(s&&typeof s=="object"||typeof s=="function")for(let t of Q(s))!Y.call(e,t)&&t!=="default"&&O(e,t,{get:()=>s[t],enumerable:!(r=J(s,t))||r.enumerable});return e},i=e=>_(g(O(e!=null?H(X(e)):{},"default",e&&e.__esModule&&"default"in e?{get:()=>e.default,enumerable:!0}:{value:e,enumerable:!0})),e);Z(exports,{combineKeys:()=>h,contextBinder:()=>C,createKeyedSignal:()=>j,createListener:()=>$,createSignal:()=>K,mergeWithKey:()=>E,partitionByKey:()=>R,selfDependant:()=>D,suspend:()=>T,suspended:()=>B,switchMapSuspended:()=>U});var A=i(require("rxjs")),h=(e,s)=>new A.Observable(r=>{let t=new Map,n=new Set,o=new Map,a=!1,l=!0,m=()=>{if(!a){let p=Object.assign(new Map(o),{changes:n});n=new Set,l=!1,r.next(p)}},b=e.subscribe(p=>{a=!0;let f=new Set(p);t.forEach((c,u)=>{f.has(u)?f.delete(u):(c.unsubscribe(),t.delete(u),o.has(u)&&(n.add(u),o.delete(u)))}),f.forEach(c=>{t.set(c,s(c).subscribe(u=>{(!o.has(c)||o.get(c)!==u)&&(n.add(c),o.set(c,u),m())},u=>{r.error(u)}))}),a=!1,(n.size||l&&!f.size)&&m()},p=>{r.error(p)},()=>{r.complete()});return()=>{b.unsubscribe(),t.forEach(p=>{p.unsubscribe()})}});var x=i(require("rxjs"));function K(e=x.identity){let s=new x.Subject;return[s.asObservable(),(...r)=>s.next(e(...r))]}var w=i(require("rxjs"));function j(e,s){let r=new Map;return[t=>{let n=new w.Observable(o=>{r.has(t)||r.set(t,new Set);let a=r.get(t);return a.add(o),()=>{a.delete(o),a.size===0&&r.delete(t)}});return n.key=t,n},(...t)=>{var a;let n=s?s(...t):t.length===2?t[1]:t[0],o=e?e(n):t[0];(a=r.get(o))==null||a.forEach(l=>{l.next(n)})}]}var v=i(require("rxjs")),G=i(require("rxjs/operators")),E=(e,...s)=>(0,v.merge)(...Object.entries(e).map(([r,t])=>(0,v.from)(t).pipe((0,G.map)(n=>({type:r,payload:n})))).concat(s));var y=i(require("@react-rxjs/core")),d=i(require("rxjs")),M=i(require("rxjs/operators"));function R(e,s,r){let t=new d.Observable(n=>{let o=new Map,a=!1,l=!1,m=e.subscribe(b=>{let p=s(b);if(o.has(p))return o.get(p).source.next(b);let f=new d.Subject,c=(0,y.shareLatest)()((r||d.identity)(f,p));c.key=p;let u={source:f,observable:c,subscription:new d.Subscription};o.set(p,u),u.subscription=c.subscribe(d.noop,q=>n.error(q),()=>{o.delete(p),n.next(S(o)),o.size===0&&l&&n.complete()}),f.next(b),n.next(S(o)),a=!0},b=>{l=!0,o.size?o.forEach(p=>p.source.error(b)):n.error(b)},()=>{l=!0,o.size?o.forEach(b=>b.source.complete()):n.complete()});return a||n.next(S(o)),()=>{m.unsubscribe(),o.forEach(b=>{b.source.unsubscribe(),b.subscription.unsubscribe()})}}).pipe((0,y.shareLatest)());return[n=>ee(t,n),t.pipe((0,M.map)(n=>Array.from(n.keys())))]}function S(e){return new Map(Array.from(e.entries()).map(([s,r])=>[s,r.observable]))}var ee=(e,s)=>{let r=new d.Observable(t=>{let n,o=e.subscribe(a=>{var l;n=n||((l=a.get(s))==null?void 0:l.subscribe(t))},a=>{t.error(a)},()=>{t.complete()});return()=>{n==null||n.unsubscribe(),o.unsubscribe()}});return r.key=s,r};var P=i(require("rxjs")),V=i(require("@react-rxjs/core"));var k=i(require("rxjs")),I=e=>s=>new k.Observable(r=>{let t=!1,n=s.subscribe(o=>{t=!0,r.next(o)},o=>{r.error(o)},()=>{r.complete()});return t||r.next(e),n});var T=e=>I(V.SUSPENSE)((0,P.from)(e));var B=()=>T;var L=i(require("rxjs")),N=i(require("rxjs/operators"));var U=e=>(0,L.pipe)((0,N.switchMap)((s,r)=>T(e(s,r))));var F=i(require("rxjs")),z=i(require("rxjs/operators")),D=()=>{let e=new F.Subject;return[e.asObservable(),()=>(0,z.tap)(e)]};var W=i(require("@react-rxjs/core")),re=e=>e();function C(...e){let s=()=>e.map(re);return function(){let[r,t]=W.bind.apply(null,arguments);return[(...n)=>r(...s(),...n),t]}}function $(...e){return K(...e)}
+var v=Object.defineProperty;var $=Object.getOwnPropertyDescriptor;var q=Object.getOwnPropertyNames;var H=Object.prototype.hasOwnProperty;var J=e=>v(e,"__esModule",{value:!0});var Q=(e,n)=>{for(var t in n)v(e,t,{get:n[t],enumerable:!0})},X=(e,n,t,o)=>{if(n&&typeof n=="object"||typeof n=="function")for(let r of q(n))!H.call(e,r)&&(t||r!=="default")&&v(e,r,{get:()=>n[r],enumerable:!(o=$(n,r))||o.enumerable});return e};var Y=(e=>(n,t)=>e&&e.get(n)||(t=X(J({}),n,1),e&&e.set(n,t),t))(typeof WeakMap!="undefined"?new WeakMap:0);var ee={};Q(ee,{combineKeys:()=>g,contextBinder:()=>D,createKeyedSignal:()=>h,createListener:()=>W,createSignal:()=>m,mergeWithKey:()=>G,partitionByKey:()=>R,selfDependant:()=>F,suspend:()=>f,suspended:()=>V,switchMapSuspended:()=>N});var x=require("rxjs"),g=(e,n)=>new x.Observable(t=>{let o=new Map,r=new Set,s=new Map,a=!1,c=!0,T=()=>{if(!a){let p=Object.assign(new Map(s),{changes:r});r=new Set,c=!1,t.next(p)}},b=e.subscribe(p=>{a=!0;let d=new Set(p);o.forEach((u,i)=>{d.has(i)?d.delete(i):(u.unsubscribe(),o.delete(i),s.has(i)&&(r.add(i),s.delete(i)))}),d.forEach(u=>{o.set(u,n(u).subscribe(i=>{(!s.has(u)||s.get(u)!==i)&&(r.add(u),s.set(u,i),T())},i=>{t.error(i)}))}),a=!1,(r.size||c&&!d.size)&&T()},p=>{t.error(p)},()=>{t.complete()});return()=>{b.unsubscribe(),o.forEach(p=>{p.unsubscribe()})}});var O=require("rxjs");function m(e=O.identity){let n=new O.Subject;return[n.asObservable(),(...t)=>n.next(e(...t))]}var A=require("rxjs");function h(e,n){let t=new Map;return[o=>{let r=new A.Observable(s=>{t.has(o)||t.set(o,new Set);let a=t.get(o);return a.add(s),()=>{a.delete(s),a.size===0&&t.delete(o)}});return r.key=o,r},(...o)=>{var a;let r=n?n(...o):o.length===2?o[1]:o[0],s=e?e(r):o[0];(a=t.get(s))==null||a.forEach(c=>{c.next(r)})}]}var K=require("rxjs"),w=require("rxjs/operators"),G=(e,...n)=>(0,K.merge)(...Object.entries(e).map(([t,o])=>(0,K.from)(o).pipe((0,w.map)(r=>({type:t,payload:r})))).concat(n));var S=require("@react-rxjs/core"),l=require("rxjs"),E=require("rxjs/operators");function R(e,n,t){let o=new l.Observable(r=>{let s=new Map,a=!1,c=!1,T=e.subscribe(b=>{let p=n(b);if(s.has(p))return s.get(p).source.next(b);let d=new l.Subject,u=(0,S.shareLatest)()((t||l.identity)(d,p));u.key=p;let i={source:d,observable:u,subscription:new l.Subscription};s.set(p,i),i.subscription=u.subscribe(l.noop,C=>r.error(C),()=>{s.delete(p),r.next(y(s)),s.size===0&&c&&r.complete()}),d.next(b),r.next(y(s)),a=!0},b=>{c=!0,s.size?s.forEach(p=>p.source.error(b)):r.error(b)},()=>{c=!0,s.size?s.forEach(b=>b.source.complete()):r.complete()});return a||r.next(y(s)),()=>{T.unsubscribe(),s.forEach(b=>{b.source.unsubscribe(),b.subscription.unsubscribe()})}}).pipe((0,S.shareLatest)());return[r=>Z(o,r),o.pipe((0,E.map)(r=>Array.from(r.keys())))]}function y(e){return new Map(Array.from(e.entries()).map(([n,t])=>[n,t.observable]))}var Z=(e,n)=>{let t=new l.Observable(o=>{let r,s=e.subscribe(a=>{var c;r=r||((c=a.get(n))==null?void 0:c.subscribe(o))},a=>{o.error(a)},()=>{o.complete()});return()=>{r==null||r.unsubscribe(),s.unsubscribe()}});return t.key=n,t};var I=require("rxjs"),P=require("@react-rxjs/core");var M=require("rxjs"),k=e=>n=>new M.Observable(t=>{let o=!1,r=n.subscribe(s=>{o=!0,t.next(s)},s=>{t.error(s)},()=>{t.complete()});return o||t.next(e),r});var f=e=>k(P.SUSPENSE)((0,I.from)(e));var V=()=>f;var j=require("rxjs"),L=require("rxjs/operators");var N=e=>(0,j.pipe)((0,L.switchMap)((n,t)=>f(e(n,t))));var U=require("rxjs"),B=require("rxjs/operators"),F=()=>{let e=new U.Subject;return[e.asObservable(),()=>(0,B.tap)(e)]};var z=require("@react-rxjs/core"),_=e=>e();function D(...e){let n=()=>e.map(_);return function(){let[t,o]=z.bind.apply(null,arguments);return[(...r)=>t(...n(),...r),o]}}function W(...e){return m(...e)}module.exports=Y(ee);
 //# sourceMappingURL=utils.cjs.production.min.js.map

dist/utils.es2017.js

 // src/combineKeys.ts
 import { Observable } from "rxjs";
 var combineKeys = (keys$, getInner$) => new Observable((observer) => {
-  const innerSubscriptions = new Map();
-  let changes = new Set();
-  const currentValue = new Map();
+  const innerSubscriptions = /* @__PURE__ */ new Map();
+  let changes = /* @__PURE__ */ new Set();
+  const currentValue = /* @__PURE__ */ new Map();
   let updatingSource = false;
@@ -14,3 +14,3 @@ let isPristine = true;
       });
-      changes = new Set();
+      changes = /* @__PURE__ */ new Set();
       isPristine = false;
@@ -72,3 +72,3 @@ observer.next(result);
 function createKeyedSignal(keySelector, mapper) {
-  const observersMap = new Map();
+  const observersMap = /* @__PURE__ */ new Map();
   return [
@@ -78,3 +78,3 @@ (key) => {
         if (!observersMap.has(key)) {
-          observersMap.set(key, new Set());
+          observersMap.set(key, /* @__PURE__ */ new Set());
         }
@@ -121,3 +121,3 @@ const set = observersMap.get(key);
   const groupedObservables$ = new Observable5((subscriber) => {
-    const groups = new Map();
+    const groups = /* @__PURE__ */ new Map();
     let emitted = false;
@@ -124,0 +124,0 @@ let sourceCompleted = false;

package.json

 {
-  "version": "0.9.3",
+  "version": "0.9.4",
   "repository": {
@@ -9,2 +9,3 @@ "type": "git",
   "sideEffects": false,
+  "type": "module",
   "exports": {
@@ -55,4 +56,4 @@ ".": {
   "devDependencies": {
-    "@react-rxjs/core": "0.8.4"
+    "@react-rxjs/core": "0.8.5"
   }
 }

No alert changes

Improved metrics

Is type module

Yes

NaN

Worsened metrics

Total package byte prevSize

134000

-47.47%

Number of package files

28

-31.71%

Lines of code

1014

-51.85%

No dependency changes