@effect/platform-node - npm Package Compare versions

Comparing version 0.0.0-snapshot-b4323ccacbf56b5c574bb69e7775d11cb8d2178a to 0.0.0-snapshot-b4e2d6446fdc267f3c789d6c141284b2dac08851

dist/cjs/internal/http/clientUndici.js

@@ -69,3 +69,3 @@ "use strict";
     origin: url.origin,
-    path: url.pathname + url.search,
+    path: url.pathname + url.search + url.hash,
     body,
@@ -72,0 +72,0 @@ // leave timeouts to Effect.timeout etc

dist/cjs/internal/http/server.js

@@ -277,4 +277,5 @@ "use strict";
     nodeResponse.writeHead(response.status, headers);
-    nodeResponse.end();
-    return Effect.void;
+    return Effect.async(resume => {
+      nodeResponse.end(() => resume(Effect.void));
+    });
   }
@@ -286,4 +287,5 @@ const body = response.body;
         nodeResponse.writeHead(response.status, headers);
-        nodeResponse.end();
-        return Effect.void;
+        return Effect.async(resume => {
+          nodeResponse.end(() => resume(Effect.void));
+        });
       }
@@ -307,4 +309,5 @@ case "Raw":
         }
-        nodeResponse.end(body.body);
-        return Effect.void;
+        return Effect.async(resume => {
+          nodeResponse.end(body.body, () => resume(Effect.void));
+        });
       }
@@ -314,4 +317,5 @@ case "Uint8Array":
         nodeResponse.writeHead(response.status, headers);
-        nodeResponse.end(body.body);
-        return Effect.void;
+        return Effect.async(resume => {
+          nodeResponse.end(body.body, () => resume(Effect.void));
+        });
       }
@@ -318,0 +322,0 @@ case "FormData":

dist/esm/internal/http/clientUndici.js

@@ -38,3 +38,3 @@ import * as Client from "@effect/platform/Http/Client";
     origin: url.origin,
-    path: url.pathname + url.search,
+    path: url.pathname + url.search + url.hash,
     body,
@@ -41,0 +41,0 @@ // leave timeouts to Effect.timeout etc

dist/esm/internal/http/server.js

@@ -240,4 +240,5 @@ import * as Etag from "@effect/platform-node-shared/Http/Etag";
     nodeResponse.writeHead(response.status, headers);
-    nodeResponse.end();
-    return Effect.void;
+    return Effect.async(resume => {
+      nodeResponse.end(() => resume(Effect.void));
+    });
   }
@@ -249,4 +250,5 @@ const body = response.body;
         nodeResponse.writeHead(response.status, headers);
-        nodeResponse.end();
-        return Effect.void;
+        return Effect.async(resume => {
+          nodeResponse.end(() => resume(Effect.void));
+        });
       }
@@ -270,4 +272,5 @@ case "Raw":
         }
-        nodeResponse.end(body.body);
-        return Effect.void;
+        return Effect.async(resume => {
+          nodeResponse.end(body.body, () => resume(Effect.void));
+        });
       }
@@ -277,4 +280,5 @@ case "Uint8Array":
         nodeResponse.writeHead(response.status, headers);
-        nodeResponse.end(body.body);
-        return Effect.void;
+        return Effect.async(resume => {
+          nodeResponse.end(body.body, () => resume(Effect.void));
+        });
       }
@@ -281,0 +285,0 @@ case "FormData":

package.json

 {
   "name": "@effect/platform-node",
-  "version": "0.0.0-snapshot-b4323ccacbf56b5c574bb69e7775d11cb8d2178a",
+  "version": "0.0.0-snapshot-b4e2d6446fdc267f3c789d6c141284b2dac08851",
   "description": "Platform specific implementations for the Node.js runtime",
@@ -14,9 +14,9 @@ "license": "MIT",
     "mime": "^3.0.0",
-    "undici": "^6.15.0",
+    "undici": "^6.18.0",
     "ws": "^8.17.0",
-    "@effect/platform-node-shared": "^0.0.0-snapshot-b4323ccacbf56b5c574bb69e7775d11cb8d2178a"
+    "@effect/platform-node-shared": "^0.0.0-snapshot-b4e2d6446fdc267f3c789d6c141284b2dac08851"
   },
   "peerDependencies": {
-    "@effect/platform": "^0.0.0-snapshot-b4323ccacbf56b5c574bb69e7775d11cb8d2178a",
-    "effect": "^0.0.0-snapshot-b4323ccacbf56b5c574bb69e7775d11cb8d2178a"
+    "@effect/platform": "^0.0.0-snapshot-b4e2d6446fdc267f3c789d6c141284b2dac08851",
+    "effect": "^0.0.0-snapshot-b4e2d6446fdc267f3c789d6c141284b2dac08851"
   },
@@ -23,0 +23,0 @@ "publishConfig": {

src/internal/http/clientUndici.ts

@@ -71,3 +71,3 @@ import type * as Body from "@effect/platform/Http/Body"
               origin: url.origin,
-              path: url.pathname + url.search,
+              path: url.pathname + url.search + url.hash,
               body,
@@ -74,0 +74,0 @@ // leave timeouts to Effect.timeout etc

src/internal/http/server.ts

@@ -402,4 +402,5 @@ import * as Etag from "@effect/platform-node-shared/Http/Etag"
       nodeResponse.writeHead(response.status, headers)
-      nodeResponse.end()
-      return Effect.void
+      return Effect.async<void>((resume) => {
+        nodeResponse.end(() => resume(Effect.void))
+      })
     }
@@ -410,4 +411,5 @@ const body = response.body
         nodeResponse.writeHead(response.status, headers)
-        nodeResponse.end()
-        return Effect.void
+        return Effect.async<void>((resume) => {
+          nodeResponse.end(() => resume(Effect.void))
+        })
       }
@@ -431,9 +433,11 @@ case "Raw": {
         }
-        nodeResponse.end(body.body)
-        return Effect.void
+        return Effect.async<void>((resume) => {
+          nodeResponse.end(body.body, () => resume(Effect.void))
+        })
       }
       case "Uint8Array": {
         nodeResponse.writeHead(response.status, headers)
-        nodeResponse.end(body.body)
-        return Effect.void
+        return Effect.async<void>((resume) => {
+          nodeResponse.end(body.body, () => resume(Effect.void))
+        })
       }
@@ -440,0 +444,0 @@ case "FormData": {

No alert changes

Improved metrics

Total package byte prevSize

341887

increased by0.4%

Lines of code

5468

increased by0.22%

Dependency changes

• Updated@effect/platform-node-shared@^0.0.0-snapshot-b4e2d6446fdc267f3c789d6c141284b2dac08851

• Updatedundici@^6.18.0