@effect/platform - npm Package Compare versions

Comparing version 0.30.1 to 0.30.2

dist/cjs/internal/http/formData.js

@@ -143,10 +143,8 @@ "use strict";
       const take = Channel.suspend(() => {
-        if (finished) {
-          return Channel.unit;
-        } else if (chunks.length === 0) {
-          return Channel.zipRight(pump, take);
+        if (chunks.length === 0) {
+          return finished ? Channel.unit : Channel.zipRight(pump, take);
         }
         const chunk = Chunk.unsafeFromArray(chunks);
         chunks = [];
-        return Channel.zipRight(Channel.write(chunk), Channel.zipRight(pump, take));
+        return finished ? Channel.write(chunk) : Channel.zipRight(Channel.write(chunk), Channel.zipRight(pump, take));
       });
@@ -153,0 +151,0 @@ partsBuffer.push(new FileImpl(info, take));

dist/esm/internal/http/formData.js

@@ -106,10 +106,8 @@ import * as Schema from "@effect/schema/Schema";
       const take = Channel.suspend(() => {
-        if (finished) {
-          return Channel.unit;
-        } else if (chunks.length === 0) {
-          return Channel.zipRight(pump, take);
+        if (chunks.length === 0) {
+          return finished ? Channel.unit : Channel.zipRight(pump, take);
         }
         const chunk = Chunk.unsafeFromArray(chunks);
         chunks = [];
-        return Channel.zipRight(Channel.write(chunk), Channel.zipRight(pump, take));
+        return finished ? Channel.write(chunk) : Channel.zipRight(Channel.write(chunk), Channel.zipRight(pump, take));
       });
@@ -116,0 +114,0 @@ partsBuffer.push(new FileImpl(info, take));

package.json

 {
   "name": "@effect/platform",
-  "version": "0.30.1",
+  "version": "0.30.2",
   "description": "Unified interfaces for common platform-specific services",
@@ -14,3 +14,3 @@ "license": "MIT",
     "find-my-way": "^7.7.0",
-    "multipasta": "^0.1.15",
+    "multipasta": "^0.1.17",
     "path-browserify": "^1.0.1"
@@ -17,0 +17,0 @@ },

src/internal/http/formData.ts

@@ -238,10 +238,8 @@ import type * as ParseResult from "@effect/schema/ParseResult"
           .suspend(() => {
-            if (finished) {
-              return Channel.unit
-            } else if (chunks.length === 0) {
-              return Channel.zipRight(pump, take)
+            if (chunks.length === 0) {
+              return finished ? Channel.unit : Channel.zipRight(pump, take)
             }
             const chunk = Chunk.unsafeFromArray(chunks)
             chunks = []
-            return Channel.zipRight(
+            return finished ? Channel.write(chunk) : Channel.zipRight(
               Channel.write(chunk),
@@ -248,0 +246,0 @@ Channel.zipRight(pump, take)

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

1237322

Worsened metrics

Lines of code

22108

decreased by-0.03%

Dependency changes

• Updatedmultipasta@^0.1.17