{"version":3,"sources":["jsdelivr-header.js","/npm/@smithy/eventstream-serde-browser@4.2.13/dist-cjs/index.js"],"names":[],"mappings":"AAAA;AACA;AACA;AACA;AACA;AACA;AACA,ACNA,aAEA,IAAI,0BAA4B,QAAQ,uCAExC,MAAM,yBAA4B,IAAmB,CACjD,CAAC,OAAO,eAAgB,kBACpB,MAAM,EAAS,EAAe,YAC9B,IACI,OAAa,CACT,MAAM,KAAE,EAAI,MAAE,SAAgB,EAAO,OACrC,GAAI,EACA,aACE,CACV,CACJ,CACA,QACI,EAAO,aACX,CACJ,IAEE,yBAA4B,IAC9B,MAAM,EAAW,EAAc,OAAO,iBACtC,OAAO,IAAI,eAAe,CACtB,UAAM,CAAK,GACP,MAAM,KAAE,EAAI,MAAE,SAAgB,EAAS,OACvC,GAAI,EACA,OAAO,EAAW,QAEtB,EAAW,QAAQ,EACvB,GACF,EAGN,MAAM,sBACF,oBACA,WAAA,EAAY,YAAE,EAAW,YAAE,IACvB,KAAK,oBAAsB,IAAI,0BAA0B,sBAAsB,CAC3E,cACA,eAER,CACA,WAAA,CAAY,EAAM,GACd,MAAM,EAAe,iBAAiB,GAAQ,yBAAyB,GAAQ,EAC/E,OAAO,KAAK,oBAAoB,YAAY,EAAc,EAC9D,CACA,SAAA,CAAU,EAAO,GACb,MAAM,EAAqB,KAAK,oBAAoB,UAAU,EAAO,GACrE,MAAiC,mBAAnB,eAAgC,yBAAyB,GAAsB,CACjG,EAEJ,MAAM,iBAAoB,GAAmC,mBAAnB,gBAAiC,aAAgB,eAErF,yBAA4B,GAAY,IAAI,sBAAsB,GAExE,QAAQ,sBAAwB,sBAChC,QAAQ,yBAA2B,yBACnC,QAAQ,yBAA2B,yBACnC,QAAQ,yBAA2B","file":"/npm/@smithy/eventstream-serde-browser@4.2.13/dist-cjs/index.js","sourceRoot":"","sourcesContent":["/**\n * Minified by jsDelivr using Terser v5.39.0.\n * Original file: /npm/@smithy/eventstream-serde-browser@4.2.13/dist-cjs/index.js\n *\n * Do NOT use SRI with dynamically generated files! More information: https://www.jsdelivr.com/using-sri-with-dynamic-files\n */\n","'use strict';\n\nvar eventstreamSerdeUniversal = require('@smithy/eventstream-serde-universal');\n\nconst readableStreamtoIterable = (readableStream) => ({\n    [Symbol.asyncIterator]: async function* () {\n        const reader = readableStream.getReader();\n        try {\n            while (true) {\n                const { done, value } = await reader.read();\n                if (done)\n                    return;\n                yield value;\n            }\n        }\n        finally {\n            reader.releaseLock();\n        }\n    },\n});\nconst iterableToReadableStream = (asyncIterable) => {\n    const iterator = asyncIterable[Symbol.asyncIterator]();\n    return new ReadableStream({\n        async pull(controller) {\n            const { done, value } = await iterator.next();\n            if (done) {\n                return controller.close();\n            }\n            controller.enqueue(value);\n        },\n    });\n};\n\nclass EventStreamMarshaller {\n    universalMarshaller;\n    constructor({ utf8Encoder, utf8Decoder }) {\n        this.universalMarshaller = new eventstreamSerdeUniversal.EventStreamMarshaller({\n            utf8Decoder,\n            utf8Encoder,\n        });\n    }\n    deserialize(body, deserializer) {\n        const bodyIterable = isReadableStream(body) ? readableStreamtoIterable(body) : body;\n        return this.universalMarshaller.deserialize(bodyIterable, deserializer);\n    }\n    serialize(input, serializer) {\n        const serialziedIterable = this.universalMarshaller.serialize(input, serializer);\n        return typeof ReadableStream === \"function\" ? iterableToReadableStream(serialziedIterable) : serialziedIterable;\n    }\n}\nconst isReadableStream = (body) => typeof ReadableStream === \"function\" && body instanceof ReadableStream;\n\nconst eventStreamSerdeProvider = (options) => new EventStreamMarshaller(options);\n\nexports.EventStreamMarshaller = EventStreamMarshaller;\nexports.eventStreamSerdeProvider = eventStreamSerdeProvider;\nexports.iterableToReadableStream = iterableToReadableStream;\nexports.readableStreamtoIterable = readableStreamtoIterable;\n"]}