@magnetarjs/core - npm Package Compare versions

Comparing version 0.6.1 to 0.6.2

dist/index.js

@@ -803,9 +803,2 @@ "use strict";
     const fetchPromises = (0, import_getorset_anything.mapGetOrSet)(fetchPromiseMap, pathFilterIdentifier, () => /* @__PURE__ */ new Map());
-    if (!closeStreamFnMap.has(pathFilterIdentifier)) {
-      closeStreamFnMap.set(pathFilterIdentifier, () => {
-      });
-    }
-    if (!streamingPromiseMap.has(pathFilterIdentifier)) {
-      streamingPromiseMap.set(pathFilterIdentifier, null);
-    }
     function cacheStream(closeStreamFn, streamingPromise) {
@@ -820,10 +813,16 @@ closeStreamFnMap.set(pathFilterIdentifier, closeStreamFn);
       const closeStreamFn = closeStreamFnMap.get(pathFilterIdentifier);
-      if (closeStreamFn)
+      if (closeStreamFn) {
         closeStreamFn();
+        setTimeout(() => {
+          streamingPromiseMap.delete(pathFilterIdentifier);
+          closeStreamFnMap.delete(pathFilterIdentifier);
+        });
+      }
     }
     function closeAllStreams() {
       for (const [identifier, closeStreamFn] of closeStreamFnMap) {
-        const _modulePath = identifier.split(MODULE_IDENTIFIER_SPLIT)[0];
-        if (_modulePath === modulePath)
+        const openStreamPath = identifier.split(MODULE_IDENTIFIER_SPLIT)[0];
+        if (openStreamPath === modulePath || openStreamPath.startsWith(modulePath + "/")) {
           closeStreamFn();
+        }
       }
@@ -830,0 +829,0 @@ }

package.json

 {
   "name": "@magnetarjs/core",
-  "version": "0.6.1",
+  "version": "0.6.2",
   "sideEffects": false,
@@ -31,3 +31,3 @@ "description": "Magnetar core library.",
   "devDependencies": {
-    "@magnetarjs/test-utils": "0.6.1"
+    "@magnetarjs/test-utils": "0.6.2"
   },
@@ -76,3 +76,3 @@ "keywords": [
   "scripts": {
-    "build": "tsup src/index.ts --format esm,cjs --dts",
+    "build": "tsup src/index.ts --clean --format esm,cjs --dts",
     "dev": "pnpm build --watch",
@@ -79,0 +79,0 @@ "test-and-build": "npm run test && npm run build",

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

Number of medium supply chain risk alerts

2

decreased by-50%

Worsened metrics

Total package byte prevSize

108350

decreased by-57.26%

Number of package files

5

decreased by-83.33%

Lines of code

2657

decreased by-52.52%

No dependency changes