@aws-sdk/eventstream-serde-browser
Advanced tools
Comparing version 3.183.0 to 3.186.0
@@ -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 @@ |
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; | ||
}; |
import { EventStreamMarshaller } from "./EventStreamMarshaller"; | ||
export const eventStreamSerdeProvider = (options) => new EventStreamMarshaller(options); | ||
export var eventStreamSerdeProvider = function (options) { return new EventStreamMarshaller(options); }; |
@@ -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]; | ||
} | ||
}); | ||
}); | ||
}, | ||
}); | ||
}; |
{ | ||
"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 @@ }, |
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
44344
246
+ 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/types@3.186.0