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

Comparing version 3.183.0 to 3.186.0

CHANGELOG.md

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

dist-es/EventStreamMarshaller.js

 import { EventStreamMarshaller as UniversalEventStreamMarshaller } from "@aws-sdk/eventstream-serde-universal";
 import { iterableToReadableStream, readableStreamtoIterable } from "./utils";
-export class EventStreamMarshaller {
-    constructor({ utf8Encoder, utf8Decoder }) {
+var EventStreamMarshaller = (function () {
+    function EventStreamMarshaller(_a) {
+        var utf8Encoder = _a.utf8Encoder, utf8Decoder = _a.utf8Decoder;
         this.universalMarshaller = new UniversalEventStreamMarshaller({
-            utf8Decoder,
-            utf8Encoder,
+            utf8Decoder: utf8Decoder,
+            utf8Encoder: utf8Encoder,
         });
     }
-    deserialize(body, deserializer) {
-        const bodyIterable = isReadableStream(body) ? readableStreamtoIterable(body) : body;
+    EventStreamMarshaller.prototype.deserialize = function (body, deserializer) {
+        var bodyIterable = isReadableStream(body) ? readableStreamtoIterable(body) : body;
         return this.universalMarshaller.deserialize(bodyIterable, deserializer);
-    }
-    serialize(input, serializer) {
-        const serialziedIterable = this.universalMarshaller.serialize(input, serializer);
+    };
+    EventStreamMarshaller.prototype.serialize = function (input, serializer) {
+        var serialziedIterable = this.universalMarshaller.serialize(input, serializer);
         return typeof ReadableStream === "function" ? iterableToReadableStream(serialziedIterable) : serialziedIterable;
-    }
-}
-const isReadableStream = (body) => typeof ReadableStream === "function" && body instanceof ReadableStream;
+    };
+    return EventStreamMarshaller;
+}());
+export { EventStreamMarshaller };
+var isReadableStream = function (body) {
+    return typeof ReadableStream === "function" && body instanceof ReadableStream;
+};

dist-es/provider.js

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

dist-es/utils.js

@@ -1,28 +0,61 @@
-export const readableStreamtoIterable = (readableStream) => ({
-    [Symbol.asyncIterator]: async function* () {
-        const reader = readableStream.getReader();
-        try {
-            while (true) {
-                const { done, value } = await reader.read();
-                if (done)
-                    return;
-                yield value;
-            }
-        }
-        finally {
-            reader.releaseLock();
-        }
-    },
-});
-export const iterableToReadableStream = (asyncIterable) => {
-    const iterator = asyncIterable[Symbol.asyncIterator]();
+import { __asyncGenerator, __await, __awaiter, __generator } from "tslib";
+export var readableStreamtoIterable = function (readableStream) {
+    var _a;
+    return (_a = {},
+        _a[Symbol.asyncIterator] = function () {
+            return __asyncGenerator(this, arguments, function () {
+                var reader, _a, done, value;
+                return __generator(this, function (_b) {
+                    switch (_b.label) {
+                        case 0:
+                            reader = readableStream.getReader();
+                            _b.label = 1;
+                        case 1:
+                            _b.trys.push([1, , 9, 10]);
+                            _b.label = 2;
+                        case 2:
+                            if (!true) return [3, 8];
+                            return [4, __await(reader.read())];
+                        case 3:
+                            _a = _b.sent(), done = _a.done, value = _a.value;
+                            if (!done) return [3, 5];
+                            return [4, __await(void 0)];
+                        case 4: return [2, _b.sent()];
+                        case 5: return [4, __await(value)];
+                        case 6: return [4, _b.sent()];
+                        case 7:
+                            _b.sent();
+                            return [3, 2];
+                        case 8: return [3, 10];
+                        case 9:
+                            reader.releaseLock();
+                            return [7];
+                        case 10: return [2];
+                    }
+                });
+            });
+        },
+        _a);
+};
+export var iterableToReadableStream = function (asyncIterable) {
+    var iterator = asyncIterable[Symbol.asyncIterator]();
     return new ReadableStream({
-        async pull(controller) {
-            const { done, value } = await iterator.next();
-            if (done) {
-                return controller.close();
-            }
-            controller.enqueue(value);
+        pull: function (controller) {
+            return __awaiter(this, void 0, void 0, function () {
+                var _a, done, value;
+                return __generator(this, function (_b) {
+                    switch (_b.label) {
+                        case 0: return [4, iterator.next()];
+                        case 1:
+                            _a = _b.sent(), done = _a.done, value = _a.value;
+                            if (done) {
+                                return [2, controller.close()];
+                            }
+                            controller.enqueue(value);
+                            return [2];
+                    }
+                });
+            });
         },
     });
 };

package.json

 {
   "name": "@aws-sdk/eventstream-serde-browser",
-  "version": "3.183.0",
+  "version": "3.186.0",
   "scripts": {
@@ -23,4 +23,4 @@ "build": "concurrently 'yarn:build:cjs' 'yarn:build:es' 'yarn:build:types'",
   "dependencies": {
-    "@aws-sdk/eventstream-serde-universal": "3.183.0",
-    "@aws-sdk/types": "3.183.0",
+    "@aws-sdk/eventstream-serde-universal": "3.186.0",
+    "@aws-sdk/types": "3.186.0",
     "tslib": "^2.3.1"
@@ -27,0 +27,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

Improved metrics

Total package byte prevSize

44344

increased by5.12%

Lines of code

246

increased by18.27%

Dependency changes

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

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

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

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

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

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

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

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

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

• Updated@aws-sdk/types@3.186.0