chunk-hre9hchf.js
Exactly one line exceeds 1000 bytesCalls a property using bracket notation
SHA-256fd25aed24c4305b3c5d4b33eda01db698f20d55b3d0c04f915839599d8182457
MaleculeH(Db)Md
Evidence
1// @bun @bytecode
2import{g_e}from"/$bunfs/root/chunk-w8xrzqp0.js";async function M(n,y,{concurrency:o=Number.POSITIVE_INFINITY,stopOnError:c=!0,signal:i}={}){return new Promise((N,T)=>{if(n[Symbol.iterator]===void 0&&n[Symbol.asyncIterator]===void 0)throw TypeError(`Expected \`input\` to be either an \`Iterable\` or \`AsyncIterable\`, got (${typeof n})`);if(typeof y!=="function")throw TypeError("Mapper function is required");if(!(Number.isSafeInteger(o)&&o>=1||o===Number.POSITIVE_INFINITY))throw TypeError(`Expected \`concurrency\` to be an integer from 1 and up or \`Infinity\`, got \`${o}\` (${typeof o})`);let I=[],d=[],p=new Map,w=!1,s=!1,m=!1,u=0,b=0,g=n[Symbol.iterator]===void 0?n[Symbol.asyncIterator]():n[Symbol.iterator](),h=()=>{a(i.reason)},S=()=>{i?.removeEventListener("abort",h)},x=(e)=>{N(e),S()},a=(e)=>{w=!0,s=!0,T(e),S()};if(i){if(i.aborted){a(i.reason);return}i.addEventListener("abort",h,{once:!0})}let l=async()=>{if(s)return;let e=await g.next(),f=b;if(b++,e.done){if(m=!0,u===0&&!s){if(!c&&d.length>0){a(AggregateError(d));return}if(s=!0,p.size===0){x(I);return}let t=[];for(let[r,v]of I.entries()){if(p.get(r)===E)continue;t.push(v)}x(t)}return}u++,(async()=>{try{let t=await e.value;if(s)return;let r=await y(t,f);if(r===E)p.set(f,r);I[f]=r,u--,await l()}catch(t){if(c)a(t);else{d.push(t),u--;try{await l()}catch(r){a(r)}}}})()};(async()=>{for(let e=0;e<o;e++){try{await l()}catch(f){a(f);break}if(m||w)break}})()})}var E;var P=g_e(()=>{E=Symbol("skip")});P();export{M as default};