@aws-sdk/eventstream-serde-node
Advanced tools
Comparing version 3.186.0 to 3.188.0
@@ -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 @@ |
@@ -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 }; | ||
} | ||
} |
import { EventStreamMarshaller } from "./EventStreamMarshaller"; | ||
export var eventStreamSerdeProvider = function (options) { return new EventStreamMarshaller(options); }; | ||
export const eventStreamSerdeProvider = (options) => new EventStreamMarshaller(options); |
@@ -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; | ||
} | ||
} |
{ | ||
"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", |
License Policy Violation
LicenseThis package is not allowed per your license policy. Review the package's license to ensure compliance.
Found 1 instance in 1 package
License Policy Violation
LicenseThis package is not allowed per your license policy. Review the package's license to ensure compliance.
Found 1 instance in 1 package
44309
237
+ 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/types@3.188.0