1"use strict";(self.webpackChunk_N_E=self.webpackChunk_N_E||[]).push([[846],{50846:function(e,t,r){r.d(t,{EventStreamSerde:function(){return s}});var i=r(30909),a=r(62145);class s{marshaller;serializer;deserializer;serdeContext;defaultContentType;constructor({marshaller:e,serializer:t,deserializer:r,serdeContext:i,defaultContentType:a}){this.marshaller=e,this.serializer=t,this.deserializer=r,this.serdeContext=i,this.defaultContentType=a}async serializeEventStream({eventStream:e,requestSchema:t,initialRequest:r}){let i=this.marshaller,a=t.getEventStreamMember(),s=t.getMemberSchema(a),n=this.serializer,l=this.defaultContentType,o=Symbol("initialRequestMarker"),u={async *[Symbol.asyncIterator](){if(r){n.write(t,r);let e=n.flush();yield{[o]:!0,headers:{":event-type":{type:"string",value:"initial-request"},":message-type":{type:"string",value:"event"},":content-type":{type:"string",value:l}},body:e}}for await(let t of e)yield t}};return i.serialize(u,e=>{if(e[o])return{headers:e.headers,body:e.body};let t="";for(let r in e)if("__type"!==r){t=r;break}let{additionalHeaders:r,body:i,eventType:a,explicitPayloadContentType:n}=this.writeEventBody(t,s,e),u={":event-type":{type:"string",value:a},":message-type":{type:"string",value:"event"},":content-type":{type:"string",value:n??l},...r};return{headers:u,body:i}})}async deserializeEventStream({response:e,responseSchema:t,initialResponseContainer:r}){let a=this.marshaller,s=t.getEventStreamMember(),n=t.getMemberSchema(s),l=n.getMemberSchemas(),o=Symbol("initialResponseMarker"),u=a.deserialize(e.body,async e=>{let r="";for(let t in e)if("__type"!==t){r=t;break}let a=e[r].body;if("initial-response"===r){let e=await this.deserializer.read(t,a);return delete e[s],{[o]:!0,...e}}if(!(r in l))return{$unknown:e};{let t=l[r];if(t.isStructSchema()){let s={},n=!1;for(let[l,o]of t.structIterator()){let{eventHeader:t,eventPayload:u}=o.getMergedTraits();if(n=n||!!(t||u),u)o.isBlobSchema()?s[l]=a:o.isStringSchema()?s[l]=(this.serdeContext?.utf8Encoder??i.G)(a):o.isStructSchema()&&(s[l]=await this.deserializer.read(o,a));else if(t){let t=e[r].headers[l]?.value;null!=t&&(o.isNumericSchema()?t&&"object"==typeof t&&"bytes"in t?s[l]=BigInt(t.toString()):s[l]=Number(t):s[l]=t)}}if(n)return{[r]:s};if(0===a.byteLength)return{[r]:{}}}return{[r]:await this.deserializer.read(t,a)}}}),m=u[Symbol.asyncIterator](),c=await m.next();if(c.done)return u;if(c.value?.[o]){if(!t)throw Error("@smithy::core/protocols - initial-response event encountered in event stream but no response schema given.");for(let e in c.value)r[e]=c.value[e]}return{async *[Symbol.asyncIterator](){for(c?.value?.[o]||(yield c.value);;){let{done:e,value:t}=await m.next();if(e)break;yield t}}}}writeEventBody(e,t,r){let i;let s=this.serializer,n=e,l=null,o=t.getSchema()[4].includes(e),u={};if(o){let a=t.getMemberSchema(e);if(a.isStructSchema()){for(let[t,i]of a.structIterator()){let{eventHeader:a,eventPayload:s}=i.getMergedTraits();if(s)l=t;else if(a){let a=r[e][t],s="binary";i.isNumericSchema()?s=-2147483648<=a&&a<=2147483648-1?"integer":"long":i.isTimestampSchema()?s="timestamp":i.isStringSchema()?s="string":i.isBooleanSchema()&&(s="boolean"),null!=a&&(u[t]={type:s,value:a},delete r[e][t])}}if(null!==l){let t=a.getMemberSchema(l);t.isBlobSchema()?i="application/octet-stream":t.isStringSchema()&&(i="text/plain"),s.write(t,r[e][l])}else s.write(a,r[e])}else if(a.isUnitSchema())s.write(a,{});else throw Error("@smithy/core/event-streams - non-struct member not supported in event stream union.")}else{let[t,i]=r[e];n=t,s.write(15,i)}let m=s.flush()??new Uint8Array,c="string"==typeof m?(this.serdeContext?.utf8Decoder??a.$)(m):m;return{body:c,eventType:n,explicitPayloadContentType:i,additionalHeaders:u}}}}}]); 2//# sourceMappingURL=846.eb2a6107aeea8dae.js.map
Line numbers count LF bytes from the start of the resource, as the search results do. Vendor segments are library code the classifier recognised; they are stored but not indexed. Bytes are shown as Latin1 characters, one per byte.