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

Comparing version 3.118.1 to 3.120.0

CHANGELOG.md

		@@ -6,2 +6,10 @@ # Change Log

		# [3.120.0](https://github.com/aws/aws-sdk-js-v3/compare/v3.119.0...v3.120.0) (2022-06-29)

		Note: Version bump only for package @aws-sdk/eventstream-serde-universal





		## [3.118.1](https://github.com/aws/aws-sdk-js-v3/compare/v3.118.0...v3.118.1) (2022-06-27)
		@@ -8,0 +16,0 @@

dist-cjs/EventStreamMarshaller.js

		"use strict";
		Object.defineProperty(exports, "__esModule", { value: true });
		exports.EventStreamMarshaller = void 0;
		const eventstream_marshaller_1 = require("@aws-sdk/eventstream-marshaller");
		const eventstream_codec_1 = require("@aws-sdk/eventstream-codec");
		const getChunkedStream_1 = require("./getChunkedStream");
		@@ -9,3 +9,3 @@ const getUnmarshalledStream_1 = require("./getUnmarshalledStream");
		constructor({ utf8Encoder, utf8Decoder }) {
		this.eventMarshaller = new eventstream_marshaller_1.EventStreamMarshaller(utf8Encoder, utf8Decoder);
		this.eventStreamCodec = new eventstream_codec_1.EventStreamCodec(utf8Encoder, utf8Decoder);
		this.utfEncoder = utf8Encoder;
		@@ -16,3 +16,3 @@ }
		const unmarshalledStream = (0, getUnmarshalledStream_1.getUnmarshalledStream)(chunkedStream, {
		eventMarshaller: this.eventMarshaller,
		eventStreamCodec: this.eventStreamCodec,
		deserializer,
		@@ -27,3 +27,3 @@ toUtf8: this.utfEncoder,
		for await (const chunk of input) {
		const payloadBuf = self.eventMarshaller.marshall(serializer(chunk));
		const payloadBuf = self.eventStreamCodec.encode(serializer(chunk));
		yield payloadBuf;
		@@ -30,0 +30,0 @@ }

dist-cjs/getUnmarshalledStream.js

		@@ -8,3 +8,3 @@ "use strict";
		for await (const chunk of source) {
		const message = options.eventMarshaller.unmarshall(chunk);
		const message = options.eventStreamCodec.decode(chunk);
		const { value: messageType } = message.headers[":message-type"];
		@@ -11,0 +11,0 @@ if (messageType === "error") {

dist-es/EventStreamMarshaller.js

		import { __asyncGenerator, __asyncValues, __await, __generator } from "tslib";
		import { EventStreamMarshaller as EventMarshaller } from "@aws-sdk/eventstream-marshaller";
		import { EventStreamCodec } from "@aws-sdk/eventstream-codec";
		import { getChunkedStream } from "./getChunkedStream";
		@@ -8,3 +8,3 @@ import { getUnmarshalledStream } from "./getUnmarshalledStream";
		var utf8Encoder = _a.utf8Encoder, utf8Decoder = _a.utf8Decoder;
		this.eventMarshaller = new EventMarshaller(utf8Encoder, utf8Decoder);
		this.eventStreamCodec = new EventStreamCodec(utf8Encoder, utf8Decoder);
		this.utfEncoder = utf8Encoder;
		@@ -15,3 +15,3 @@ }
		var unmarshalledStream = getUnmarshalledStream(chunkedStream, {
		eventMarshaller: this.eventMarshaller,
		eventStreamCodec: this.eventStreamCodec,
		deserializer: deserializer,
		@@ -39,3 +39,3 @@ toUtf8: this.utfEncoder,
		chunk = input_1_1.value;
		payloadBuf = self.eventMarshaller.marshall(serializer(chunk));
		payloadBuf = self.eventStreamCodec.encode(serializer(chunk));
		return [4, __await(payloadBuf)];
		@@ -42,0 +42,0 @@ case 3: return [4, _b.sent()];

dist-es/getUnmarshalledStream.js

		@@ -20,3 +20,3 @@ import { __asyncGenerator, __asyncValues, __await, __generator } from "tslib";
		chunk = source_1_1.value;
		message = options.eventMarshaller.unmarshall(chunk);
		message = options.eventStreamCodec.decode(chunk);
		messageType = message.headers[":message-type"].value;
		@@ -23,0 +23,0 @@ if (!(messageType === "error")) return [3, 3];

dist-types/EventStreamMarshaller.d.ts

		@@ -9,3 +9,3 @@ import { Decoder, Encoder, EventStreamMarshaller as IEventStreamMarshaller, Message } from "@aws-sdk/types";
		export declare class EventStreamMarshaller {
		private readonly eventMarshaller;
		private readonly eventStreamCodec;
		private readonly utfEncoder;
		@@ -12,0 +12,0 @@ constructor({ utf8Encoder, utf8Decoder }: EventStreamMarshallerOptions);

dist-types/getUnmarshalledStream.d.ts

		@@ -1,5 +0,5 @@
		import { EventStreamMarshaller as EventMarshaller } from "@aws-sdk/eventstream-marshaller";
		import { EventStreamCodec } from "@aws-sdk/eventstream-codec";
		import { Encoder, Message } from "@aws-sdk/types";
		export declare type UnmarshalledStreamOptions<T> = {
		eventMarshaller: EventMarshaller;
		eventStreamCodec: EventStreamCodec;
		deserializer: (input: Record<string, Message>) => Promise<T>;
		@@ -6,0 +6,0 @@ toUtf8: Encoder;

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

		@@ -9,3 +9,3 @@ import { Decoder, Encoder, EventStreamMarshaller as IEventStreamMarshaller, Message } from "@aws-sdk/types";
		export declare class EventStreamMarshaller {
		private readonly eventMarshaller;
		private readonly eventStreamCodec;
		private readonly utfEncoder;
		@@ -12,0 +12,0 @@ constructor({ utf8Encoder, utf8Decoder }: EventStreamMarshallerOptions);

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

		@@ -1,5 +0,5 @@
		import { EventStreamMarshaller as EventMarshaller } from "@aws-sdk/eventstream-marshaller";
		import { EventStreamCodec } from "@aws-sdk/eventstream-codec";
		import { Encoder, Message } from "@aws-sdk/types";
		export declare type UnmarshalledStreamOptions<T> = {
		eventMarshaller: EventMarshaller;
		eventStreamCodec: EventStreamCodec;
		deserializer: (input: Record<string, Message>) => Promise<T>;
		@@ -6,0 +6,0 @@ toUtf8: Encoder;

package.json

		{
		"name": "@aws-sdk/eventstream-serde-universal",
		"version": "3.118.1",
		"version": "3.120.0",
		"scripts": {
		@@ -22,3 +22,3 @@ "build": "concurrently 'yarn:build:cjs' 'yarn:build:es' 'yarn:build:types'",
		"dependencies": {
		"@aws-sdk/eventstream-marshaller": "3.118.1",
		"@aws-sdk/eventstream-codec": "3.119.0",
		"@aws-sdk/types": "3.110.0",
		@@ -25,0 +25,0 @@ "tslib": "^2.3.1"

New alerts