@aws-sdk/eventstream-codec - npm Package Compare versions

Comparing version 3.341.0 to 3.342.0

dist-cjs/EventStreamCodec.js

@@ -10,3 +10,36 @@ "use strict";
         this.headerMarshaller = new HeaderMarshaller_1.HeaderMarshaller(toUtf8, fromUtf8);
+        this.messageBuffer = [];
+        this.isEndOfStream = false;
     }
+    feed(message) {
+        this.messageBuffer.push(this.decode(message));
+    }
+    endOfStream() {
+        this.isEndOfStream = true;
+    }
+    getMessage() {
+        const message = this.messageBuffer.pop();
+        const isEndOfStream = this.isEndOfStream;
+        return {
+            getMessage() {
+                return message;
+            },
+            isEndOfStream() {
+                return isEndOfStream;
+            },
+        };
+    }
+    getAvailableMessages() {
+        const messages = this.messageBuffer;
+        this.messageBuffer = [];
+        const isEndOfStream = this.isEndOfStream;
+        return {
+            getMessages() {
+                return messages;
+            },
+            isEndOfStream() {
+                return isEndOfStream;
+            },
+        };
+    }
     encode({ headers: rawHeaders, body }) {
@@ -13,0 +46,0 @@ const headers = this.headerMarshaller.format(rawHeaders);

dist-cjs/index.js

@@ -5,3 +5,8 @@ "use strict";
 tslib_1.__exportStar(require("./EventStreamCodec"), exports);
+tslib_1.__exportStar(require("./HeaderMarshaller"), exports);
 tslib_1.__exportStar(require("./Int64"), exports);
 tslib_1.__exportStar(require("./Message"), exports);
+tslib_1.__exportStar(require("./MessageDecoderStream"), exports);
+tslib_1.__exportStar(require("./MessageEncoderStream"), exports);
+tslib_1.__exportStar(require("./SmithyMessageDecoderStream"), exports);
+tslib_1.__exportStar(require("./SmithyMessageEncoderStream"), exports);

dist-es/EventStreamCodec.js

@@ -7,3 +7,36 @@ import { Crc32 } from "@aws-crypto/crc32";
         this.headerMarshaller = new HeaderMarshaller(toUtf8, fromUtf8);
+        this.messageBuffer = [];
+        this.isEndOfStream = false;
     }
+    feed(message) {
+        this.messageBuffer.push(this.decode(message));
+    }
+    endOfStream() {
+        this.isEndOfStream = true;
+    }
+    getMessage() {
+        const message = this.messageBuffer.pop();
+        const isEndOfStream = this.isEndOfStream;
+        return {
+            getMessage() {
+                return message;
+            },
+            isEndOfStream() {
+                return isEndOfStream;
+            },
+        };
+    }
+    getAvailableMessages() {
+        const messages = this.messageBuffer;
+        this.messageBuffer = [];
+        const isEndOfStream = this.isEndOfStream;
+        return {
+            getMessages() {
+                return messages;
+            },
+            isEndOfStream() {
+                return isEndOfStream;
+            },
+        };
+    }
     encode({ headers: rawHeaders, body }) {
@@ -10,0 +43,0 @@ const headers = this.headerMarshaller.format(rawHeaders);

dist-es/index.js

 export * from "./EventStreamCodec";
+export * from "./HeaderMarshaller";
 export * from "./Int64";
 export * from "./Message";
+export * from "./MessageDecoderStream";
+export * from "./MessageEncoderStream";
+export * from "./SmithyMessageDecoderStream";
+export * from "./SmithyMessageEncoderStream";

dist-types/EventStreamCodec.d.ts

@@ -1,2 +0,2 @@
-import { Message, MessageHeaders } from "@aws-sdk/types";
+import { AvailableMessage, AvailableMessages, Message, MessageDecoder, MessageEncoder, MessageHeaders } from "@aws-sdk/types";
 import { Decoder, Encoder } from "@aws-sdk/types";
@@ -7,5 +7,11 @@ /**
  */
-export declare class EventStreamCodec {
+export declare class EventStreamCodec implements MessageEncoder, MessageDecoder {
     private readonly headerMarshaller;
+    private messageBuffer;
+    private isEndOfStream;
     constructor(toUtf8: Encoder, fromUtf8: Decoder);
+    feed(message: ArrayBufferView): void;
+    endOfStream(): void;
+    getMessage(): AvailableMessage;
+    getAvailableMessages(): AvailableMessages;
     /**
@@ -12,0 +18,0 @@ * Convert a structured JavaScript object with tagged headers into a binary

dist-types/index.d.ts

 export * from "./EventStreamCodec";
+export * from "./HeaderMarshaller";
 export * from "./Int64";
 export * from "./Message";
+export * from "./MessageDecoderStream";
+export * from "./MessageEncoderStream";
+export * from "./SmithyMessageDecoderStream";
+export * from "./SmithyMessageEncoderStream";

dist-types/ts3.4/EventStreamCodec.d.ts

@@ -1,6 +0,21 @@
-import { Message, MessageHeaders } from "@aws-sdk/types";
+import {
+  AvailableMessage,
+  AvailableMessages,
+  Message,
+  MessageDecoder,
+  MessageEncoder,
+  MessageHeaders,
+} from "@aws-sdk/types";
 import { Decoder, Encoder } from "@aws-sdk/types";
-export declare class EventStreamCodec {
+export declare class EventStreamCodec
+  implements MessageEncoder, MessageDecoder
+{
   private readonly headerMarshaller;
+  private messageBuffer;
+  private isEndOfStream;
   constructor(toUtf8: Encoder, fromUtf8: Decoder);
+  feed(message: ArrayBufferView): void;
+  endOfStream(): void;
+  getMessage(): AvailableMessage;
+  getAvailableMessages(): AvailableMessages;
   encode({ headers: rawHeaders, body }: Message): Uint8Array;
@@ -7,0 +22,0 @@ decode(message: ArrayBufferView): Message;

dist-types/ts3.4/index.d.ts

 export * from "./EventStreamCodec";
+export * from "./HeaderMarshaller";
 export * from "./Int64";
 export * from "./Message";
+export * from "./MessageDecoderStream";
+export * from "./MessageEncoderStream";
+export * from "./SmithyMessageDecoderStream";
+export * from "./SmithyMessageEncoderStream";

package.json

 {
   "name": "@aws-sdk/eventstream-codec",
-  "version": "3.341.0",
+  "version": "3.342.0",
   "scripts": {
@@ -24,3 +24,3 @@ "build": "concurrently 'yarn:build:cjs' 'yarn:build:es' 'yarn:build:types'",
     "@aws-crypto/crc32": "3.0.0",
-    "@aws-sdk/types": "3.341.0",
+    "@aws-sdk/types": "3.342.0",
     "@aws-sdk/util-hex-encoding": "3.310.0",
@@ -27,0 +27,0 @@ "tslib": "^2.5.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

69747

increased by18.99%

Number of package files

51

increased by45.71%

Lines of code

1450

increased by33.15%

Dependency changes

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

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

• Updated@aws-sdk/types@3.342.0