@smithy/util-stream - npm Package Compare versions

Comparing version 4.5.12 to 4.5.13

dist-cjs/checksum/ChecksumStream.js

@@ -12,2 +12,3 @@ "use strict";
     base64Encoder;
+    pendingCallback = null;
     constructor({ expectedChecksum, checksum, source, checksumSourceLocation, base64Encoder, }) {
@@ -27,7 +28,17 @@ super();
     }
-    _read(size) { }
+    _read(size) {
+        if (this.pendingCallback) {
+            const callback = this.pendingCallback;
+            this.pendingCallback = null;
+            callback();
+        }
+    }
     _write(chunk, encoding, callback) {
         try {
             this.checksum.update(chunk);
-            this.push(chunk);
+            const canPushMore = this.push(chunk);
+            if (!canPushMore) {
+                this.pendingCallback = callback;
+                return;
+            }
         }
@@ -34,0 +45,0 @@ catch (e) {

dist-es/checksum/ChecksumStream.js

@@ -9,2 +9,3 @@ import { toBase64 } from "@smithy/util-base64";
     base64Encoder;
+    pendingCallback = null;
     constructor({ expectedChecksum, checksum, source, checksumSourceLocation, base64Encoder, }) {
@@ -24,7 +25,17 @@ super();
     }
-    _read(size) { }
+    _read(size) {
+        if (this.pendingCallback) {
+            const callback = this.pendingCallback;
+            this.pendingCallback = null;
+            callback();
+        }
+    }
     _write(chunk, encoding, callback) {
         try {
             this.checksum.update(chunk);
-            this.push(chunk);
+            const canPushMore = this.push(chunk);
+            if (!canPushMore) {
+                this.pendingCallback = callback;
+                return;
+            }
         }
@@ -31,0 +42,0 @@ catch (e) {

dist-types/checksum/ChecksumStream.d.ts

@@ -41,2 +41,3 @@ import type { Checksum, Encoder } from "@smithy/types";
     private base64Encoder;
+    private pendingCallback;
     constructor({ expectedChecksum, checksum, source, checksumSourceLocation, base64Encoder, }: ChecksumStreamInit<Readable>);
@@ -43,0 +44,0 @@ /**

dist-types/ts3.4/checksum/ChecksumStream.d.ts

@@ -41,2 +41,3 @@ import { Checksum, Encoder } from "@smithy/types";
     private base64Encoder;
+    private pendingCallback;
     constructor({ expectedChecksum, checksum, source, checksumSourceLocation, base64Encoder, }: ChecksumStreamInit<Readable>);
@@ -43,0 +44,0 @@ /**

package.json

 {
   "name": "@smithy/util-stream",
-  "version": "4.5.12",
+  "version": "4.5.13",
   "scripts": {
@@ -5,0 +5,0 @@ "build": "concurrently 'yarn:build:cjs' 'yarn:build:es' 'yarn:build:types && yarn build:types:downlevel'",

New alerts

Network access

Supply chain risk

This module accesses the network.

Found 1 instance in 1 package

Fixed alerts

Network access

Supply chain risk

This module accesses the network.

Found 1 instance in 1 package

Improved metrics

Total package byte prevSize

88227

0.83%

Lines of code

1951

1.25%

No dependency changes