1!function(){try{var e="undefined"!=typeof window?window:"undefined"!=typeof global?global:"undefined"!=typeof self?self:{},t=(new e.Error).stack;t&&(e._sentryDebugIds=e._sentryDebugIds||{},e._sentryDebugIds[t]="01935e8d-8525-4418-b0b6-f415bbe9bd11",e._sentryDebugIdIdentifier="sentry-dbid-01935e8d-8525-4418-b0b6-f415bbe9bd11")}catch(e){}}();"use strict";(self.webpackChunk_N_E=self.webpackChunk_N_E||[]).push([[3719],{13719:function(e,t,r){r.d(t,{EventStreamSerde:function(){return n}});var i=r(21555),s=r(99492);class n{marshaller;serializer;deserializer;serdeContext;defaultContentType;constructor({marshaller:e,serializer:t,deserializer:r,serdeContext:i,defaultContentType:s}){this.marshaller=e,this.serializer=t,this.deserializer=r,this.serdeContext=i,this.defaultContentType=s}async serializeEventStream({eventStream:e,requestSchema:t,initialRequest:r}){let i=this.marshaller,s=t.getEventStreamMember(),n=t.getMemberSchema(s),a=this.serializer,l=this.defaultContentType,o=Symbol("initialRequestMarker"),d={async *[Symbol.asyncIterator](){if(r){a.write(t,r);let e=a.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(d,e=>{if(e[o])return{headers:e.headers,body:e.body};let t=Object.keys(e).find(e=>"__type"!==e)??"",{additionalHeaders:r,body:i,eventType:s,explicitPayloadContentType:a}=this.writeEventBody(t,n,e);return{headers:{":event-type":{type:"string",value:s},":message-type":{type:"string",value:"event"},":content-type":{type:"string",value:a??l},...r},body:i}})}async deserializeEventStream({response:e,responseSchema:t,initialResponseContainer:r}){let s=this.marshaller,n=t.getEventStreamMember(),a=t.getMemberSchema(n).getMemberSchemas(),l=Symbol("initialResponseMarker"),o=s.deserialize(e.body,async e=>{let r=Object.keys(e).find(e=>"__type"!==e)??"",s=e[r].body;if("initial-response"===r){let e=await this.deserializer.read(t,s);return delete e[n],{[l]:!0,...e}}if(!(r in a))return{$unknown:e};{let t=a[r];if(t.isStructSchema()){let n={},a=!1;for(let[l,o]of t.structIterator()){let{eventHeader:t,eventPayload:d}=o.getMergedTraits();if(a=a||!!(t||d),d)o.isBlobSchema()?n[l]=s:o.isStringSchema()?n[l]=(this.serdeContext?.utf8Encoder??i.G)(s):o.isStructSchema()&&(n[l]=await this.deserializer.read(o,s));else if(t){let t=e[r].headers[l]?.value;null!=t&&(o.isNumericSchema()?t&&"object"==typeof t&&"bytes"in t?n[l]=BigInt(t.toString()):n[l]=Number(t):n[l]=t)}}if(a)return{[r]:n};if(0===s.byteLength)return{[r]:{}}}return{[r]:await this.deserializer.read(t,s)}}}),d=o[Symbol.asyncIterator](),u=await d.next();if(u.done)return o;if(u.value?.[l]){if(!t)throw Error("@smithy::core/protocols - initial-response event encountered in event stream but no response schema given.");for(let[e,t]of Object.entries(u.value))r[e]=t}return{async *[Symbol.asyncIterator](){for(u?.value?.[l]||(yield u.value);;){let{done:e,value:t}=await d.next();if(e)break;yield t}}}}writeEventBody(e,t,r){let i;let n=this.serializer,a=e,l=null,o=t.getSchema()[4].includes(e),d={};if(o){let s=t.getMemberSchema(e);if(s.isStructSchema()){for(let[t,i]of s.structIterator()){let{eventHeader:s,eventPayload:n}=i.getMergedTraits();if(n)l=t;else if(s){let s=r[e][t],n="binary";i.isNumericSchema()?n=-2147483648<=s&&s<=2147483648-1?"integer":"long":i.isTimestampSchema()?n="timestamp":i.isStringSchema()?n="string":i.isBooleanSchema()&&(n="boolean"),null!=s&&(d[t]={type:n,value:s},delete r[e][t])}}if(null!==l){let t=s.getMemberSchema(l);t.isBlobSchema()?i="application/octet-stream":t.isStringSchema()&&(i="text/plain"),n.write(t,r[e][l])}else n.write(s,r[e])}else if(s.isUnitSchema())n.write(s,{});else throw Error("@smithy/core/event-streams - non-struct member not supported in event stream union.")}else{let[t,i]=r[e];a=t,n.write(15,i)}let u=n.flush()??new Uint8Array;return{body:"string"==typeof u?(this.serdeContext?.utf8Decoder??s.$)(u):u,eventType:a,explicitPayloadContentType:i,additionalHeaders:d}}}}}]);
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.