https://www.leipziger-jobanzeiger.de/_next/static/chunks/5669.746a817a445c00fb.js

1!function(){try{var e="u">typeof window?window:"u">typeof global?global:"u">typeof globalThis?globalThis:"u">typeof self?self:{};e._sentryModuleMetadata=e._sentryModuleMetadata||{},e._sentryModuleMetadata[(new e.Error).stack]=function(e){for(var t=1;t<arguments.length;t++){var r=arguments[t];if(null!=r)for(var a in r)r.hasOwnProperty(a)&&(e[a]=r[a])}return e}({},e._sentryModuleMetadata[(new e.Error).stack],{"_sentryBundlerPluginAppKey:takumi-application":!0});var t=(new e.Error).stack;t&&(e._sentryDebugIds=e._sentryDebugIds||{},e._sentryDebugIds[t]="f581d2de-fd1f-435a-87bb-c16d3b3697df",e._sentryDebugIdIdentifier="sentry-dbid-f581d2de-fd1f-435a-87bb-c16d3b3697df")}catch(e){}}();"use strict";(self.webpackChunk_N_E=self.webpackChunk_N_E||[]).push([[5669],{15669:(e,t,r)=>{r.d(t,{EventStreamSerde:()=>L,eventStreamSerdeProvider:()=>O});let a=new Uint32Array(256);for(let e=0;e<256;++e){let t=e;for(let e=0;e<8;++e)t=1&t?0xedb88320^t>>>1:t>>>1;a[e]=t>>>0}class s{digestLength=4;checksum=0xffffffff;update(e){for(let t=0;t<e.length;++t)this.checksum=this.checksum>>>8^a[(this.checksum^e[t])&255]}digestSync(){return(0xffffffff^this.checksum)>>>0}async digest(){let e=this.digestSync(),t=new Uint8Array(4);return new DataView(t.buffer).setUint32(0,e,!1),t}reset(){this.checksum=0xffffffff}}var n,i,l=r(76342);class o{bytes;constructor(e){if(this.bytes=e,8!==e.byteLength)throw Error("Int64 buffers must be exactly 8 bytes")}static fromNumber(e){if(e>0x8000000000000000||e<-0x8000000000000000)throw Error(`${e} is too large (or, if negative, too small) to represent as an Int64`);let t=new Uint8Array(8);for(let r=7,a=Math.abs(Math.round(e));r>-1&&a>0;r--,a/=256)t[r]=a;return e<0&&f(t),new o(t)}valueOf(){let e=this.bytes.slice(0),t=128&e[0];return t&&f(e),parseInt((0,l.n)(e),16)*(t?-1:1)}toString(){return String(this.valueOf())}}function f(e){for(let t=0;t<8;t++)e[t]^=255;for(let t=7;t>-1&&(e[t]++,0===e[t]);t--);}class u{toUtf8;fromUtf8;constructor(e,t){this.toUtf8=e,this.fromUtf8=t}format(e){let t=[];for(let r of Object.keys(e)){let a=this.fromUtf8(r);t.push(Uint8Array.from([a.byteLength]),a,this.formatHeaderValue(e[r]))}let r=new Uint8Array(t.reduce((e,t)=>e+t.byteLength,0)),a=0;for(let e of t)r.set(e,a),a+=e.byteLength;return r}formatHeaderValue(e){switch(e.type){case"boolean":return Uint8Array.from([+!e.value]);case"byte":return Uint8Array.from([2,e.value]);case"short":let t=new DataView(new ArrayBuffer(3));return t.setUint8(0,3),t.setInt16(1,e.value,!1),new Uint8Array(t.buffer);case"integer":let r=new DataView(new ArrayBuffer(5));return r.setUint8(0,4),r.setInt32(1,e.value,!1),new Uint8Array(r.buffer);case"long":let a=new Uint8Array(9);return a[0]=5,a.set(e.value.bytes,1),a;case"binary":let s=new DataView(new ArrayBuffer(3+e.value.byteLength));s.setUint8(0,6),s.setUint16(1,e.value.byteLength,!1);let n=new Uint8Array(s.buffer);return n.set(e.value,3),n;case"string":let i=this.fromUtf8(e.value),f=new DataView(new ArrayBuffer(3+i.byteLength));f.setUint8(0,7),f.setUint16(1,i.byteLength,!1);let u=new Uint8Array(f.buffer);return u.set(i,3),u;case"timestamp":let c=new Uint8Array(9);return c[0]=8,c.set(o.fromNumber(e.value.valueOf()).bytes,1),c;case"uuid":if(!v.test(e.value))throw Error(`Invalid UUID received: ${e.value}`);let y=new Uint8Array(17);return y[0]=9,y.set((0,l.a)(e.value.replace(/\-/g,"")),1),y}}parse(e){let t={},r=0;for(;r<e.byteLength;){let a=e.getUint8(r++),s=this.toUtf8(new Uint8Array(e.buffer,e.byteOffset+r,a));switch(r+=a,e.getUint8(r++)){case 0:t[s]={type:c,value:!0};break;case 1:t[s]={type:c,value:!1};break;case 2:t[s]={type:y,value:e.getInt8(r++)};break;case 3:t[s]={type:h,value:e.getInt16(r,!1)},r+=2;break;case 4:t[s]={type:d,value:e.getInt32(r,!1)},r+=4;break;case 5:t[s]={type:m,value:new o(new Uint8Array(e.buffer,e.byteOffset+r,8))},r+=8;break;case 6:let n=e.getUint16(r,!1);r+=2,t[s]={type:b,value:new Uint8Array(e.buffer,e.byteOffset+r,n)},r+=n;break;case 7:let i=e.getUint16(r,!1);r+=2,t[s]={type:g,value:this.toUtf8(new Uint8Array(e.buffer,e.byteOffset+r,i))},r+=i;break;case 8:t[s]={type:w,value:new Date(new o(new Uint8Array(e.buffer,e.byteOffset+r,8)).valueOf())},r+=8;break;case 9:let f=new Uint8Array(e.buffer,e.byteOffset+r,16);r+=16,t[s]={type:p,value:`${(0,l.n)(f.subarray(0,4))}-${(0,l.n)(f.subarray(4,6))}-${(0,l.n)(f.subarray(6,8))}-${(0,l.n)(f.subarray(8,10))}-${(0,l.n)(f.subarray(10))}`};break;default:throw Error("Unrecognized header type tag")}}return t}}(n=i||(i={}))[n.boolTrue=0]="boolTrue",n[n.boolFalse=1]="boolFalse",n[n.byte=2]="byte",n[n.short=3]="short",n[n.integer=4]="integer",n[n.long=5]="long",n[n.byteArray=6]="byteArray",n[n.string=7]="string",n[n.timestamp=8]="timestamp",n[n.uuid=9]="uuid";let c="boolean",y="byte",h="short",d="integer",m="long",b="binary",g="string",w="timestamp",p="uuid",v=/^[a-f0-9]{8}-[a-f0-9]{4}-[a-f0-9]{4}-[a-f0-9]{4}-[a-f0-9]{12}$/,S=16;class U{headerMarshaller;messageBuffer;isEndOfStream;constructor(e,t){this.headerMarshaller=new u(e,t),this.messageBuffer=[],this.isEndOfStream=!1}feed(e){this.messageBuffer.push(this.decode(e))}endOfStream(){this.isEndOfStream=!0}getMessage(){let e=this.messageBuffer.pop(),t=this.isEndOfStream;return{getMessage:()=>

1e,isEndOfStream:()=>t}}getAvailableMessages(){let e=this.messageBuffer;this.messageBuffer=[];let t=this.isEndOfStream;return{getMessages:()=>e,isEndOfStream:()=>t}}encode({headers:e,body:t}){let r=this.headerMarshaller.format(e),a=r.byteLength+t.byteLength+16,n=new Uint8Array(a),i=new DataView(n.buffer,n.byteOffset,n.byteLength),l=new s;return i.setUint32(0,a,!1),i.setUint32(4,r.byteLength,!1),l.update(n.subarray(0,8)),i.setUint32(8,l.digestSync(),!1),n.set(r,12),n.set(t,r.byteLength+12),l.update(n.subarray(8,a-4)),i.setUint32(a-4,l.digestSync(),!1),n}decode(e){let{headers:t,body:r}=function({byteLength:e,byteOffset:t,buffer:r}){if(e<S)throw Error("Provided message too short to accommodate event stream message overhead");let a=new DataView(r,t,e),n=a.getUint32(0,!1);if(e!==n)throw Error("Reported message length does not match received message length");let i=a.getUint32(4,!1),l=a.getUint32(8,!1),o=a.getUint32(e-4,!1),f=new s;if(f.update(new Uint8Array(r,t,8)),l!==f.digestSync())throw Error(`The prelude checksum specified in the message (${l}) does not match the calculated CRC32 checksum (${f.digestSync()})`);if(f.update(new Uint8Array(r,t+8,e-12)),o!==f.digestSync())throw Error(`The message checksum (${f.digestSync()}) did not match the expected value of ${o}`);return{headers:new DataView(r,t+8+4,i),body:new Uint8Array(r,t+8+4+i,n-i-16)}}(e);return{headers:this.headerMarshaller.parse(t),body:r}}formatHeaders(e){return this.headerMarshaller.format(e)}}class E{options;constructor(e){this.options=e}[Symbol.asyncIterator](){return this.asyncIterator()}async *asyncIterator(){for await(let e of this.options.inputStream){let t=this.options.decoder.decode(e);yield t}}}class k{options;constructor(e){this.options=e}[Symbol.asyncIterator](){return this.asyncIterator()}async *asyncIterator(){for await(let e of this.options.messageStream){let t=this.options.encoder.encode(e);yield t}this.options.includeEndFrame&&(yield new Uint8Array(0))}}class A{options;constructor(e){this.options=e}[Symbol.asyncIterator](){return this.asyncIterator()}async *asyncIterator(){for await(let e of this.options.messageStream){let t=await this.options.deserializer(e);void 0!==t&&(yield t)}}}class I{options;constructor(e){this.options=e}[Symbol.asyncIterator](){return this.asyncIterator()}async *asyncIterator(){for await(let e of this.options.inputStream){let t=this.options.serializer(e);yield t}}}class M{eventStreamCodec;utfEncoder;constructor({utf8Encoder:e,utf8Decoder:t}){this.eventStreamCodec=new U(e,t),this.utfEncoder=e}deserialize(e,t){var r;let a,s,n,i,l;return new A({messageStream:new E({inputStream:(a=0,s=0,n=null,i=null,l=e=>{if("number"!=typeof e)throw Error("Attempted to allocate an event message where size was not a number: "+e);a=e,s=4,new DataView((n=new Uint8Array(e)).buffer).setUint32(0,e,!1)},{[Symbol.asyncIterator]:async function*(){let t=e[Symbol.asyncIterator]();for(;;){let{value:e,done:r}=await t.next();if(r){if(a)if(a===s)yield n;else throw Error("Truncated event message received.");return}let o=e.length,f=0;for(;f<o;){if(!n){let t=o-f;i||(i=new Uint8Array(4));let r=Math.min(4-s,t);if(i.set(e.slice(f,f+r),s),s+=r,f+=r,s<4)break;l(new DataView(i.buffer).getUint32(0,!1)),i=null}let t=Math.min(a-s,o-f);n.set(e.slice(f,f+t),s),s+=t,f+=t,a&&a===s&&(yield n,n=null,a=0,s=0)}}}}),decoder:this.eventStreamCodec}),deserializer:(r=this.utfEncoder,async function(e){let{value:a}=e.headers[":message-type"];if("error"===a){let t=Error(e.headers[":error-message"].value||"UnknownError");throw t.name=e.headers[":error-code"].value,t}if("exception"===a){let a=e.headers[":exception-type"].value,s=await t({[a]:e});if(s.$unknown){let t=Error(r(e.body));throw t.name=a,t}throw s[a]}if("event"===a){let r={[e.headers[":event-type"].value]:e},a=await t(r);if(a.$unknown)return;return a}throw Error(`Unrecognizable event type: ${e.headers[":event-type"].value}`)})})}serialize(e,t){return new k({messageStream:new I({inputStream:e,serializer:t}),encoder:this.eventStreamCodec,includeEndFrame:!0})}}class z{universalMarshaller;constructor({utf8Encoder:e,utf8Decoder:t}){this.universalMarshaller=new M({utf8Decoder:t,utf8Encoder:e})}deserialize(e,t){let r=x(e)?{[Symbol.asyncIterator]:async function*(){let t=e.getReader();try{for(;;){let{done:e,value:r}=await t.read();if(e)return;yield r}}finally{t.releaseLock()}}}:e;return this.universalMarshaller.deserialize(r,t)}serialize(e,t){let r,a=this.universalMarshaller.serialize(e,t);return"function"==typeof ReadableStream?(r=a[Symbol.asyncIterator](),new ReadableStream({async pull(e){let{done:t,value:a}=await r.next();if(t)return e.close();e.enqueue(a)}})):a}}let x=e=>"function"==typeof ReadableStream&&e instanceof ReadableStream,O=e=>new z(e);var B=r(13665),D=r(63732);class L{marshaller;

1serializer;deserializer;serdeContext;defaultContentType;constructor({marshaller:e,serializer:t,deserializer:r,serdeContext:a,defaultContentType:s}){this.marshaller=e,this.serializer=t,this.deserializer=r,this.serdeContext=a,this.defaultContentType=s}async serializeEventStream({eventStream:e,requestSchema:t,initialRequest:r}){let a=this.marshaller,s=t.getEventStreamMember(),n=t.getMemberSchema(s),i=this.serializer,l=this.defaultContentType,o=Symbol("initialRequestMarker"),f={async *[Symbol.asyncIterator](){if(r){i.write(t,r);let e=i.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 a.serialize(f,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:a,eventType:s,explicitPayloadContentType:i}=this.writeEventBody(t,n,e);return{headers:{":event-type":{type:"string",value:s},":message-type":{type:"string",value:"event"},":content-type":{type:"string",value:i??l},...r},body:a}})}async deserializeEventStream({response:e,responseSchema:t,initialResponseContainer:r}){let a=this.marshaller,s=t.getEventStreamMember(),n=t.getMemberSchema(s).getMemberSchemas(),i=Symbol("initialResponseMarker"),l=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],{[i]:!0,...e}}if(!(r in n))return{$unknown:e};{let t=n[r];if(t.isStructSchema()){let s={},n=!1;for(let[i,l]of t.structIterator()){let{eventHeader:t,eventPayload:o}=l.getMergedTraits();if(n=n||!!(t||o),o)l.isBlobSchema()?s[i]=a:l.isStringSchema()?s[i]=(this.serdeContext?.utf8Encoder??B.P)(a):l.isStructSchema()&&(s[i]=await this.deserializer.read(l,a));else if(t){let t=e[r].headers[i]?.value;null!=t&&(l.isNumericSchema()?t&&"object"==typeof t&&"bytes"in t?s[i]=BigInt(t.toString()):s[i]=Number(t):s[i]=t)}}if(n)return{[r]:s};if(0===a.byteLength)return{[r]:{}}}return{[r]:await this.deserializer.read(t,a)}}}),o=l[Symbol.asyncIterator](),f=await o.next();if(f.done)return l;if(f.value?.[i]){if(!t)throw Error("@smithy::core/protocols - initial-response event encountered in event stream but no response schema given.");for(let e in f.value)r[e]=f.value[e]}return{async *[Symbol.asyncIterator](){for(f?.value?.[i]||(yield f.value);;){let{done:e,value:t}=await o.next();if(e)break;yield t}}}}writeEventBody(e,t,r){let a,s=this.serializer,n=e,i=null,l=t.getSchema()[4].includes(e),o={};if(l){let n=t.getMemberSchema(e);if(n.isStructSchema()){for(let[t,a]of n.structIterator()){let{eventHeader:s,eventPayload:n}=a.getMergedTraits();if(n)i=t;else if(s){let s=r[e][t],n="binary";a.isNumericSchema()?n=-0x80000000<=s&&s<=0x80000000-1?"integer":"long":a.isTimestampSchema()?n="timestamp":a.isStringSchema()?n="string":a.isBooleanSchema()&&(n="boolean"),null!=s&&(o[t]={type:n,value:s},delete r[e][t])}}if(null!==i){let t=n.getMemberSchema(i);t.isBlobSchema()?a="application/octet-stream":t.isStringSchema()&&(a="text/plain"),s.write(t,r[e][i])}else s.write(n,r[e])}else if(n.isUnitSchema())s.write(n,{});else throw Error("@smithy/core/event-streams - non-struct member not supported in event stream union.")}else{let[t,a]=r[e];n=t,s.write(15,a)}let f=s.flush()??new Uint8Array;return{body:"string"==typeof f?(this.serdeContext?.utf8Decoder??D.a)(f):f,eventType:n,explicitPayloadContentType:a,additionalHeaders:o}}}}}]);