let __return,DISPATCHER_JS="const _m=(()=>{let __export;var _=(t)=>URL.createObjectURL(new Blob([t],{type:\"text/javascript\"})),d=async(t,r)=>{if(typeof Worker==\"function\"){typeof Deno<\"u\"&&(r=!0);try{let e=r?new Worker(t,{type:\"module\"}):new Worker(t);return e.onerror=(s)=>{s&&typeof s.preventDefault==\"function\"&&s.preventDefault(),console.error(\"unhandled error from worker: \"+s.message)},{listen:(s)=>e.onmessage=({data:o})=>s(o),postMessage:e.postMessage.bind(e),terminate:e.terminate.bind(e)}}catch(e){throw console.error(e),Error(\"Worker is not supported in this environment\",{cause:e})}}try{let e=await Function('return import(\"node:worker_threads\")')(),s=await(await fetch(t)).text(),o=new e.Worker(s,{eval:!0});return o.on(\"error\",(n)=>{console.error(\"unhandled error from worker: \"+n)}),{listen:(n)=>o.on(\"message\",n),postMessage:o.postMessage.bind(o),terminate:o.terminate.bind(o)}}catch(e){throw console.error(e),Error(\"Worker is not supported in this environment\",{cause:e})}},f=async()=>{if(typeof WorkerGlobalScope<\"u\"&&self instanceof WorkerGlobalScope)return{listen:(t)=>self.onmessage=({data:r})=>t(r),postMessage:self.postMessage.bind(self),terminate:()=>self.close()};try{let t=(await Function('return import(\"node:worker_threads\")')()).parentPort;return{listen:(r)=>t.on(\"message\",r),postMessage:t.postMessage.bind(t),terminate:t.close.bind(t)}}catch(t){throw Error(\"Failed to setup worker global scope\",{cause:t})}};__export=async(t)=>{let r;try{r=await t}catch(s){throw console.error(s),s}let e=await f();e.listen(async(s)=>{let{recv:o,start_send:n,script:g,memory:p,wasm:c,useESWorker:b}=s,l=_(g);for(r.initSync({memory:p,module:c}),r.__unsafe_pistonite_wbgspawn_send_signal(n);;){let w=await r.__pistonite_wbgspawn_dispatch_recv(o);if(!w)break;let[y,m,h,k]=w,a=await d(l,b);for(await new Promise((i)=>{let u=!1;a.listen(async(M)=>{switch(M){case 1:return a.postMessage({f:y,send:m,start:h,memory:p,wasm:c}),i();case 0:a.terminate();return;case 2:u||(u=!0,r.__unsafe_pistonite_wbgspawn_send_panic(m)),a.terminate();return;default:a.terminate()}})});r.__unsafe_pistonite_wbgspawn_poll_signal(k)===!1;)await new Promise((i)=>setTimeout(i,0))}r.__pistonite_wbgspawn_dispatch_drop(o),URL.revokeObjectURL(l),e.postMessage(0)}),e.postMessage(1)};\n;return __export})();",WORKER_JS="const _m=(()=>{let __export;var n=async()=>{if(typeof WorkerGlobalScope<\"u\"&&self instanceof WorkerGlobalScope)return{listen:(e)=>self.onmessage=({data:r})=>e(r),postMessage:self.postMessage.bind(self),terminate:()=>self.close()};try{let e=(await Function('return import(\"node:worker_threads\")')()).parentPort;return{listen:(r)=>e.on(\"message\",r),postMessage:e.postMessage.bind(e),terminate:e.close.bind(e)}}catch(e){throw Error(\"Failed to setup worker global scope\",{cause:e})}};__export=async(e)=>{let r;try{r=await e}catch(o){throw console.error(o),o}let t=await n();t.listen(async(o)=>{let{f:a,send:i,start:l,memory:p,wasm:c}=o;r.initSync({memory:p,module:c});try{let s=!1;globalThis.__pistonite_wbgspawn_worker_terminate=(m)=>{m?(s=!0,t.postMessage(2)):t.postMessage(0),t.terminate()},await r.__pistonite_wbgspawn_worker_main(a,i,l),s||t.postMessage(0)}catch{t.postMessage(2)}await new Promise((s)=>setTimeout(s,1000)),t.terminate()}),t.postMessage(1)};\n;return __export})();";var d=(o)=>URL.createObjectURL(new Blob([o],{type:"text/javascript"})),u=async(o,n)=>{if(typeof Worker=="function"){typeof Deno<"u"&&(n=!0);try{let e=n?new Worker(o,{type:"module"}):new Worker(o);return e.onerror=(r)=>{r&&typeof r.preventDefault=="function"&&r.preventDefault(),console.error("unhandled error from worker: "+r.message)},{listen:(r)=>e.onmessage=({data:t})=>r(t),postMessage:e.postMessage.bind(e),terminate:e.terminate.bind(e)}}catch(e){throw console.error(e),Error("Worker is not supported in this environment",{cause:e})}}try{let e=await Function('return import("node:worker_threads")')(),r=await(await fetch(o)).text(),t=new e.Worker(r,{eval:!0});return t.on("error",(s)=>{console.error("unhandled error from worker: "+s)}),{listen:(s)=>t.on("message",s),postMessage:t.postMessage.bind(t),terminate:t.terminate.bind(t)}}catch(e){throw console.error(e),Error("Worker is not supported in this environment",{cause:e})}};__return=(async()=>{let[o,n,e,r,t,s]=ARGS,i=!1,c,l;switch(o){case 1:c=`${n}
${WORKER_JS};_m(wasm_bindgen)`,l=`${n}
${DISPATCHER_JS};_m(wasm_bindgen)`;break;case 2:{let a;if(typeof Window=="function"||typeof WorkerGlobalScope=="function")a=`(async()=>{
const bg=URL.createObjectURL(new Blob([${JSON.stringify(n)}], {type:"text/javascript"}));
try{return await import(bg)}finally{URL.revokeObjectURL(bg)}
})()`;else{let m=`data:text/javascript;base64,${Buffer.from(n).toString("base64")}`;a=`(async()=>{return await import(${JSON.stringify(m)})})()`}c=`${WORKER_JS};_m(${a})`,l=`${DISPATCHER_JS};_m(${a})`,i=!0;break}default:throw Error("(Unexpected) Invalid bg_target passed to wasm-bindgen-spawn thread creator")}let f=d(l),p=await u(f,i);await new Promise((a)=>{p.listen(async(m)=>{if(m){a(),p.postMessage({recv:t,start_send:s,script:c,memory:r,wasm:e,useESWorker:i}),URL.revokeObjectURL(f);return}p.terminate()})})})();
;return __return;