1var C=Object.defineProperty;var E=(g,t,i)=>t in g?C(g,t,{enumerable:!0,configurable:!0,writable:!0,value:i}):g[t]=i;var z=(g,t,i)=>E(g,typeof t!="symbol"?t+"":t,i);import{a7 as I,a8 as B}from"./index-B33eox3o.js";import"./vendor-DK739Z2k.js";class U{constructor({marshaller:t,serializer:i,deserializer:l,serdeContext:c,defaultContentType:y}){z(this,"marshaller");z(this,"serializer");z(this,"deserializer");z(this,"serdeContext");z(this,"defaultContentType");this.marshaller=t,this.serializer=i,this.deserializer=l,this.serdeContext=c,this.defaultContentType=y}async serializeEventStream({eventStream:t,requestSchema:i,initialRequest:l}){const c=this.marshaller,y=i.getEventStreamMember(),S=i.getMemberSchema(y),d=this.serializer,h=this.defaultContentType,f=Symbol("initialRequestMarker"),u={async*[Symbol.asyncIterator](){if(l){const a={":event-type":{type:"string",value:"initial-request"},":message-type":{type:"string",value:"event"},":content-type":{type:"string",value:h}};d.write(i,l);const m=d.flush();yield{[f]:!0,headers:a,body:m}}for await(const a of t)yield a}};return c.serialize(u,a=>{if(a[f])return{headers:a.headers,body:a.body};let m="";for(const s in a)if(s!=="__type"){m=s;break}const{additionalHeaders:r,body:e,eventType:n,explicitPayloadContentType:v}=this.writeEventBody(m,S,a);return{headers:{":event-type":{type:"string",value:n},":message-type":{type:"string",value:"event"},":content-type":{type:"string",value:v??h},...r},body:e}})}async deserializeEventStream({response:t,responseSchema:i,initialResponseContainer:l}){var m;const c=this.marshaller,y=i.getEventStreamMember(),d=i.getMemberSchema(y).getMemberSchemas(),h=Symbol("initialResponseMarker"),f=c.deserialize(t.body,async r=>{var v,k;let e="";for(const s in r)if(s!=="__type"){e=s;break}const n=r[e].body;if(e==="initial-response"){const s=await this.deserializer.read(i,n);return delete s[y],{[h]:!0,...s}}else if(e in d){const s=d[e];if(s.isStructSchema()){const o={};let x=!1;for(const[p,w]of s.structIterator()){const{eventHeader:M,eventPayload:T}=w.getMergedTraits();if(x=x||!!(M||T),T)w.isBlobSchema()?o[p]=n:w.isStringSchema()?o[p]=(((v=this.serdeContext)==null?void 0:v.utf8Encoder)??I)(n):w.isStructSchema()&&(o[p]=await this.deserializer.read(w,n));else if(M){const b=(k=r[e].headers[p])==null?void 0:k.value;b!=null&&(w.isNumericSchema()?b&&typeof b=="object"&&"bytes"in b?o[p]=BigInt(b.toString()):o[p]=Number(b):o[p]=b)}}if(x)return{[e]:o};if(n.byteLength===0)return{[e]:{}}}return{[e]:await this.deserializer.read(s,n)}}else return{$unknown:r}}),u=f[Symbol.asyncIterator](),a=await u.next();if(a.done)return f;if((m=a.value)!=null&&m[h]){if(!i)throw new Error("@smithy::core/protocols - initial-response event encountered in event stream but no response schema given.");for(const r in a.value)l[r]=a.value[r]}return{async*[Symbol.asyncIterator](){var r;for((r=a==null?void 0:a.value)!=null&&r[h]||(yield a.value);;){const{done:e,value:n}=await u.next();if(e)break;yield n}}}}writeEventBody(t,i,l){var m;const c=this.serializer;let y=t,S=null,d;const h=i.getSchema()[4].includes(t),f={};if(h){const r=i.getMemberSchema(t);if(r.isStructSchema()){for(const[e,n]of r.structIterator()){const{eventHeader:v,eventPayload:k}=n.getMergedTraits();if(k)S=e;else if(v){const s=l[t][e];let o="binary";n.isNumericSchema()?(-2)**31<=s&&s<=2**31-1?o="integer":o="long":n.isTimestampSchema()?o="timestamp":n.isStringSchema()?o="string":n.isBooleanSchema()&&(o="boolean"),s!=null&&(f[e]={type:o,value:s},delete l[t][e])}}if(S!==null){const e=r.getMemberSchema(S);e.isBlobSchema()?d="application/octet-stream":e.isStringSchema()&&(d="text/plain"),c.write(e,l[t][S])}else c.write(r,l[t])}else if(r.isUnitSchema())c.write(r,{});else throw new Error("@smithy/core/event-streams - non-struct member not supported in event stream union.")}else{const[r,e]=l[t];y=r,c.write(15,e)}const u=c.flush()??new Uint8Array;return{body:typeof u=="string"?(((m=this.serdeContext)==null?void 0:m.utf8Decoder)??B)(u):u,eventType:y,explicitPayloadContentType:d,additionalHeaders:f}}}export{U as EventStreamSerde};
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.