@smithy/eventstream-serde-browser
Advanced tools
Comparing version 2.0.16 to 2.1.0
@@ -1,23 +0,1 @@ | ||
"use strict"; | ||
Object.defineProperty(exports, "__esModule", { value: true }); | ||
exports.EventStreamMarshaller = void 0; | ||
const eventstream_serde_universal_1 = require("@smithy/eventstream-serde-universal"); | ||
const utils_1 = require("./utils"); | ||
class EventStreamMarshaller { | ||
constructor({ utf8Encoder, utf8Decoder }) { | ||
this.universalMarshaller = new eventstream_serde_universal_1.EventStreamMarshaller({ | ||
utf8Decoder, | ||
utf8Encoder, | ||
}); | ||
} | ||
deserialize(body, deserializer) { | ||
const bodyIterable = isReadableStream(body) ? (0, utils_1.readableStreamtoIterable)(body) : body; | ||
return this.universalMarshaller.deserialize(bodyIterable, deserializer); | ||
} | ||
serialize(input, serializer) { | ||
const serialziedIterable = this.universalMarshaller.serialize(input, serializer); | ||
return typeof ReadableStream === "function" ? (0, utils_1.iterableToReadableStream)(serialziedIterable) : serialziedIterable; | ||
} | ||
} | ||
exports.EventStreamMarshaller = EventStreamMarshaller; | ||
const isReadableStream = (body) => typeof ReadableStream === "function" && body instanceof ReadableStream; | ||
module.exports = require("./index.js"); |
@@ -1,6 +0,101 @@ | ||
"use strict"; | ||
Object.defineProperty(exports, "__esModule", { value: true }); | ||
const tslib_1 = require("tslib"); | ||
tslib_1.__exportStar(require("./EventStreamMarshaller"), exports); | ||
tslib_1.__exportStar(require("./provider"), exports); | ||
tslib_1.__exportStar(require("./utils"), exports); | ||
var __defProp = Object.defineProperty; | ||
var __getOwnPropDesc = Object.getOwnPropertyDescriptor; | ||
var __getOwnPropNames = Object.getOwnPropertyNames; | ||
var __hasOwnProp = Object.prototype.hasOwnProperty; | ||
var __name = (target, value) => __defProp(target, "name", { value, configurable: true }); | ||
var __export = (target, all) => { | ||
for (var name in all) | ||
__defProp(target, name, { get: all[name], enumerable: true }); | ||
}; | ||
var __copyProps = (to, from, except, desc) => { | ||
if (from && typeof from === "object" || typeof from === "function") { | ||
for (let key of __getOwnPropNames(from)) | ||
if (!__hasOwnProp.call(to, key) && key !== except) | ||
__defProp(to, key, { get: () => from[key], enumerable: !(desc = __getOwnPropDesc(from, key)) || desc.enumerable }); | ||
} | ||
return to; | ||
}; | ||
var __toCommonJS = (mod) => __copyProps(__defProp({}, "__esModule", { value: true }), mod); | ||
// src/index.ts | ||
var src_exports = {}; | ||
__export(src_exports, { | ||
EventStreamMarshaller: () => EventStreamMarshaller, | ||
eventStreamSerdeProvider: () => eventStreamSerdeProvider, | ||
iterableToReadableStream: () => iterableToReadableStream, | ||
readableStreamtoIterable: () => readableStreamtoIterable | ||
}); | ||
module.exports = __toCommonJS(src_exports); | ||
// src/EventStreamMarshaller.ts | ||
var import_eventstream_serde_universal = require("@smithy/eventstream-serde-universal"); | ||
// src/utils.ts | ||
var readableStreamtoIterable = /* @__PURE__ */ __name((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(); | ||
} | ||
} | ||
}), "readableStreamtoIterable"); | ||
var iterableToReadableStream = /* @__PURE__ */ __name((asyncIterable) => { | ||
const iterator = asyncIterable[Symbol.asyncIterator](); | ||
return new ReadableStream({ | ||
async pull(controller) { | ||
const { done, value } = await iterator.next(); | ||
if (done) { | ||
return controller.close(); | ||
} | ||
controller.enqueue(value); | ||
} | ||
}); | ||
}, "iterableToReadableStream"); | ||
// src/EventStreamMarshaller.ts | ||
var _EventStreamMarshaller = class _EventStreamMarshaller { | ||
constructor({ utf8Encoder, utf8Decoder }) { | ||
this.universalMarshaller = new import_eventstream_serde_universal.EventStreamMarshaller({ | ||
utf8Decoder, | ||
utf8Encoder | ||
}); | ||
} | ||
deserialize(body, deserializer) { | ||
const bodyIterable = isReadableStream(body) ? readableStreamtoIterable(body) : body; | ||
return this.universalMarshaller.deserialize(bodyIterable, deserializer); | ||
} | ||
/** | ||
* Generate a stream that serialize events into stream of binary chunks; | ||
* | ||
* Caveat is that streaming request payload doesn't work on browser with native | ||
* xhr or fetch handler currently because they don't support upload streaming. | ||
* reference: | ||
* * https://bugs.chromium.org/p/chromium/issues/detail?id=688906 | ||
* * https://bugzilla.mozilla.org/show_bug.cgi?id=1387483 | ||
* | ||
*/ | ||
serialize(input, serializer) { | ||
const serialziedIterable = this.universalMarshaller.serialize(input, serializer); | ||
return typeof ReadableStream === "function" ? iterableToReadableStream(serialziedIterable) : serialziedIterable; | ||
} | ||
}; | ||
__name(_EventStreamMarshaller, "EventStreamMarshaller"); | ||
var EventStreamMarshaller = _EventStreamMarshaller; | ||
var isReadableStream = /* @__PURE__ */ __name((body) => typeof ReadableStream === "function" && body instanceof ReadableStream, "isReadableStream"); | ||
// src/provider.ts | ||
var eventStreamSerdeProvider = /* @__PURE__ */ __name((options) => new EventStreamMarshaller(options), "eventStreamSerdeProvider"); | ||
// Annotate the CommonJS export names for ESM import in node: | ||
0 && (module.exports = { | ||
EventStreamMarshaller, | ||
eventStreamSerdeProvider, | ||
iterableToReadableStream, | ||
readableStreamtoIterable | ||
}); |
@@ -1,6 +0,1 @@ | ||
"use strict"; | ||
Object.defineProperty(exports, "__esModule", { value: true }); | ||
exports.eventStreamSerdeProvider = void 0; | ||
const EventStreamMarshaller_1 = require("./EventStreamMarshaller"); | ||
const eventStreamSerdeProvider = (options) => new EventStreamMarshaller_1.EventStreamMarshaller(options); | ||
exports.eventStreamSerdeProvider = eventStreamSerdeProvider; | ||
module.exports = require("./index.js"); |
@@ -1,33 +0,1 @@ | ||
"use strict"; | ||
Object.defineProperty(exports, "__esModule", { value: true }); | ||
exports.iterableToReadableStream = exports.readableStreamtoIterable = void 0; | ||
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(); | ||
} | ||
}, | ||
}); | ||
exports.readableStreamtoIterable = readableStreamtoIterable; | ||
const iterableToReadableStream = (asyncIterable) => { | ||
const iterator = asyncIterable[Symbol.asyncIterator](); | ||
return new ReadableStream({ | ||
async pull(controller) { | ||
const { done, value } = await iterator.next(); | ||
if (done) { | ||
return controller.close(); | ||
} | ||
controller.enqueue(value); | ||
}, | ||
}); | ||
}; | ||
exports.iterableToReadableStream = iterableToReadableStream; | ||
module.exports = require("./index.js"); |
{ | ||
"name": "@smithy/eventstream-serde-browser", | ||
"version": "2.0.16", | ||
"version": "2.1.0", | ||
"scripts": { | ||
"build": "concurrently 'yarn:build:cjs' 'yarn:build:es' 'yarn:build:types && yarn build:types:downlevel'", | ||
"build:cjs": "yarn g:tsc -p tsconfig.cjs.json", | ||
"build:cjs": "node ../../scripts/inline eventstream-serde-browser", | ||
"build:es": "yarn g:tsc -p tsconfig.es.json", | ||
@@ -25,4 +25,4 @@ "build:types": "yarn g:tsc -p tsconfig.types.json", | ||
"dependencies": { | ||
"@smithy/eventstream-serde-universal": "^2.0.16", | ||
"@smithy/types": "^2.8.0", | ||
"@smithy/eventstream-serde-universal": "^2.1.0", | ||
"@smithy/types": "^2.9.0", | ||
"tslib": "^2.5.0" | ||
@@ -29,0 +29,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
25750
298