@aws-sdk/eventstream-serde-node - npm Package Compare versions

Comparing version 3.186.0 to 3.188.0

CHANGELOG.md

@@ -6,2 +6,10 @@ # Change Log
 
+# [3.188.0](https://github.com/aws/aws-sdk-js-v3/compare/v3.187.0...v3.188.0) (2022-10-13)
+
+**Note:** Version bump only for package @aws-sdk/eventstream-serde-node
+
+
+
+
+
 # [3.186.0](https://github.com/aws/aws-sdk-js-v3/compare/v3.185.0...v3.186.0) (2022-10-06)
@@ -8,0 +16,0 @@

dist-es/EventStreamMarshaller.js

@@ -1,19 +0,17 @@
-import { __awaiter, __generator } from "tslib";
 import { EventStreamMarshaller as UniversalEventStreamMarshaller } from "@aws-sdk/eventstream-serde-universal";
 import { Readable } from "stream";
 import { readabletoIterable } from "./utils";
-var EventStreamMarshaller = (function () {
-    function EventStreamMarshaller(_a) {
-        var utf8Encoder = _a.utf8Encoder, utf8Decoder = _a.utf8Decoder;
+export class EventStreamMarshaller {
+    constructor({ utf8Encoder, utf8Decoder }) {
         this.universalMarshaller = new UniversalEventStreamMarshaller({
-            utf8Decoder: utf8Decoder,
-            utf8Encoder: utf8Encoder,
+            utf8Decoder,
+            utf8Encoder,
         });
     }
-    EventStreamMarshaller.prototype.deserialize = function (body, deserializer) {
-        var bodyIterable = typeof body[Symbol.asyncIterator] === "function" ? body : readabletoIterable(body);
+    deserialize(body, deserializer) {
+        const bodyIterable = typeof body[Symbol.asyncIterator] === "function" ? body : readabletoIterable(body);
         return this.universalMarshaller.deserialize(bodyIterable, deserializer);
-    };
-    EventStreamMarshaller.prototype.serialize = function (input, serializer) {
-        var serializedIterable = this.universalMarshaller.serialize(input, serializer);
+    }
+    serialize(input, serializer) {
+        const serializedIterable = this.universalMarshaller.serialize(input, serializer);
         if (typeof Readable.from === "function") {
@@ -23,40 +21,31 @@ return Readable.from(serializedIterable);
         else {
-            var iterator_1 = serializedIterable[Symbol.asyncIterator]();
-            var serializedStream_1 = new Readable({
+            const iterator = serializedIterable[Symbol.asyncIterator]();
+            const serializedStream = new Readable({
                 autoDestroy: true,
                 objectMode: true,
-                read: function () {
-                    return __awaiter(this, void 0, void 0, function () {
-                        var _this = this;
-                        return __generator(this, function (_a) {
-                            iterator_1
-                                .next()
-                                .then(function (_a) {
-                                var done = _a.done, value = _a.value;
-                                if (done) {
-                                    _this.push(null);
-                                }
-                                else {
-                                    _this.push(value);
-                                }
-                            })
-                                .catch(function (err) {
-                                _this.destroy(err);
-                            });
-                            return [2];
-                        });
+                async read() {
+                    iterator
+                        .next()
+                        .then(({ done, value }) => {
+                        if (done) {
+                            this.push(null);
+                        }
+                        else {
+                            this.push(value);
+                        }
+                    })
+                        .catch((err) => {
+                        this.destroy(err);
                     });
                 },
             });
-            serializedStream_1.on("error", function () {
-                serializedStream_1.destroy();
+            serializedStream.on("error", () => {
+                serializedStream.destroy();
             });
-            serializedStream_1.on("end", function () {
-                serializedStream_1.destroy();
+            serializedStream.on("end", () => {
+                serializedStream.destroy();
             });
-            return serializedStream_1;
+            return serializedStream;
         }
-    };
-    return EventStreamMarshaller;
-}());
-export { EventStreamMarshaller };
+    }
+}

dist-es/provider.js

 import { EventStreamMarshaller } from "./EventStreamMarshaller";
-export var eventStreamSerdeProvider = function (options) { return new EventStreamMarshaller(options); };
+export const eventStreamSerdeProvider = (options) => new EventStreamMarshaller(options);

dist-es/utils.js

@@ -1,44 +0,26 @@
-import { __asyncGenerator, __await, __generator } from "tslib";
-export function readabletoIterable(readStream) {
-    return __asyncGenerator(this, arguments, function readabletoIterable_1() {
-        var streamEnded, generationEnded, records, value;
-        return __generator(this, function (_a) {
-            switch (_a.label) {
-                case 0:
-                    streamEnded = false;
-                    generationEnded = false;
-                    records = new Array();
-                    readStream.on("error", function (err) {
-                        if (!streamEnded) {
-                            streamEnded = true;
-                        }
-                        if (err) {
-                            throw err;
-                        }
-                    });
-                    readStream.on("data", function (data) {
-                        records.push(data);
-                    });
-                    readStream.on("end", function () {
-                        streamEnded = true;
-                    });
-                    _a.label = 1;
-                case 1:
-                    if (!!generationEnded) return [3, 6];
-                    return [4, __await(new Promise(function (resolve) { return setTimeout(function () { return resolve(records.shift()); }, 0); }))];
-                case 2:
-                    value = _a.sent();
-                    if (!value) return [3, 5];
-                    return [4, __await(value)];
-                case 3: return [4, _a.sent()];
-                case 4:
-                    _a.sent();
-                    _a.label = 5;
-                case 5:
-                    generationEnded = streamEnded && records.length === 0;
-                    return [3, 1];
-                case 6: return [2];
-            }
-        });
+export async function* readabletoIterable(readStream) {
+    let streamEnded = false;
+    let generationEnded = false;
+    const records = new Array();
+    readStream.on("error", (err) => {
+        if (!streamEnded) {
+            streamEnded = true;
+        }
+        if (err) {
+            throw err;
+        }
     });
+    readStream.on("data", (data) => {
+        records.push(data);
+    });
+    readStream.on("end", () => {
+        streamEnded = true;
+    });
+    while (!generationEnded) {
+        const value = await new Promise((resolve) => setTimeout(() => resolve(records.shift()), 0));
+        if (value) {
+            yield value;
+        }
+        generationEnded = streamEnded && records.length === 0;
+    }
 }

package.json

 {
   "name": "@aws-sdk/eventstream-serde-node",
-  "version": "3.186.0",
+  "version": "3.188.0",
   "scripts": {
@@ -23,8 +23,8 @@ "build": "concurrently 'yarn:build:cjs' 'yarn:build:es' 'yarn:build:types'",
   "dependencies": {
-    "@aws-sdk/eventstream-serde-universal": "3.186.0",
-    "@aws-sdk/types": "3.186.0",
+    "@aws-sdk/eventstream-serde-universal": "3.188.0",
+    "@aws-sdk/types": "3.188.0",
     "tslib": "^2.3.1"
   },
   "devDependencies": {
-    "@aws-sdk/util-utf8-node": "3.186.0",
+    "@aws-sdk/util-utf8-node": "3.188.0",
     "@tsconfig/recommended": "1.0.1",
@@ -31,0 +31,0 @@ "@types/node": "^12.0.0",

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

Worsened metrics

Total package byte prevSize

44309

decreased by-3.71%

Lines of code

237

decreased by-10.9%

Dependency changes

• + Added@aws-sdk/eventstream-codec@3.188.0(transitive)

• + Added@aws-sdk/eventstream-serde-universal@3.188.0(transitive)

• + Added@aws-sdk/types@3.188.0(transitive)

• + Added@aws-sdk/util-hex-encoding@3.188.0(transitive)

• - Removed@aws-sdk/eventstream-codec@3.186.0(transitive)

• - Removed@aws-sdk/eventstream-serde-universal@3.186.0(transitive)

• - Removed@aws-sdk/types@3.186.0(transitive)

• - Removed@aws-sdk/util-hex-encoding@3.186.0(transitive)

• Updated@aws-sdk/eventstream-serde-universal@3.188.0

• Updated@aws-sdk/types@3.188.0