OwlCyberSecurity - MANAGER

Edit File: asyncIterator.js.map

{"version":3,"names":["_asyncIterator","iterable","method","async","sync","retry","Symbol","asyncIterator","iterator","call","AsyncFromSyncIterator","TypeError","s","n","next","prototype","AsyncFromSyncIteratorContinuation","apply","arguments","return","value","ret","undefined","Promise","resolve","done","throw","maybeError","thr","reject","r","Object","then"],"sources":["../../src/helpers/asyncIterator.ts"],"sourcesContent":["/* @minVersion 7.15.9 */\n\ntype AsyncIteratorFn<T> = AsyncIterable<T>[typeof Symbol.asyncIterator];\ntype SyncIteratorFn<T> = Iterable<T>[typeof Symbol.iterator];\n\nexport default function _asyncIterator<T>(\n iterable: AsyncIterable<T> | Iterable<T>,\n) {\n var method: AsyncIteratorFn<T> | SyncIteratorFn<T>,\n async: typeof Symbol.asyncIterator | \"@@asyncIterator\" | undefined,\n sync: typeof Symbol.iterator | \"@@iterator\" | undefined,\n retry = 2;\n\n if (typeof Symbol !== \"undefined\") {\n async = Symbol.asyncIterator;\n sync = Symbol.iterator;\n }\n\n while (retry--) {\n // TypeScript doesn't have in-function narrowing, and TypeScript can't narrow\n // AsyncIterable<T> | Iterable<T> down to AsyncIterable<T>. So let's use any here.\n if (async && (method = (iterable as any)[async]) != null) {\n return (method as AsyncIteratorFn<T>).call(iterable as AsyncIterable<T>);\n }\n // Same here, TypeScript can't narrow AsyncIterable<T> | Iterable<T> down to Iterable<T>.\n if (sync && (method = (iterable as any)[sync]) != null) {\n return new AsyncFromSyncIterator(\n (method as SyncIteratorFn<T>).call(iterable as Iterable<T>),\n );\n }\n\n async = \"@@asyncIterator\";\n sync = \"@@iterator\";\n }\n\n throw new TypeError(\"Object is not async iterable\");\n}\n\n// AsyncFromSyncIterator is actually a class that implements AsyncIterator interface\ndeclare class AsyncFromSyncIterator<T = any, TReturn = any, TNext = undefined>\n implements AsyncIterator<T, TReturn, TNext>\n{\n s: Iterator<T>;\n n: Iterator<T>[\"next\"];\n constructor(s: Iterator<T>);\n\n next(...args: [] | [TNext]): Promise<IteratorResult<T, TReturn>>;\n return?(\n value?: TReturn | PromiseLike<TReturn>,\n ): Promise<IteratorResult<T, TReturn>>;\n throw?(e?: any): Promise<IteratorResult<T, TReturn>>;\n}\n\n// Actual implementation of AsyncFromSyncIterator starts here\n// class only exists in ES6, so we need to use the old school way\n// This makes ESLint and TypeScript complain a lot, but it's the only way\nfunction AsyncFromSyncIterator<T, TReturn = any, TNext = undefined>(s: any) {\n // @ts-expect-error - Intentionally overriding the constructor.\n AsyncFromSyncIterator = function (\n this: AsyncFromSyncIterator,\n s: Iterator<T>,\n ) {\n this.s = s;\n this.n = s.next;\n };\n AsyncFromSyncIterator.prototype = {\n // Initiating the \"s\" and \"n\", use \"any\" to prevent TS from complaining\n /* SyncIterator */ s: null as any,\n /* SyncIterator.[[Next]] */ n: null as any,\n next: function () {\n return AsyncFromSyncIteratorContinuation<T, TReturn>(\n // Use \"arguments\" here for better compatibility and smaller bundle size\n // Itentionally casting \"arguments\" to an array for the type of func.apply\n this.n.apply(this.s, arguments as any as [] | [undefined]),\n );\n },\n return: function (value) {\n var ret = this.s.return;\n if (ret === undefined) {\n return Promise.resolve<IteratorReturnResult<TReturn>>({\n // \"TReturn | PromiseLike<TReturn>\" should have been unwrapped by Awaited<T>,\n // but TypeScript choked, let's just casting it away\n value: value as TReturn,\n done: true,\n });\n }\n return AsyncFromSyncIteratorContinuation<T, TReturn>(\n ret.apply(\n this.s,\n // Use \"arguments\" here for better compatibility and smaller bundle size\n // Itentionally casting \"arguments\" to an array for the type of func.apply\n arguments as any as [] | [TReturn | PromiseLike<TReturn>],\n ),\n );\n },\n throw: function (maybeError?: any) {\n var thr = this.s.return;\n if (thr === undefined) {\n // eslint-disable-next-line @typescript-eslint/prefer-promise-reject-errors\n return Promise.reject(maybeError);\n }\n return AsyncFromSyncIteratorContinuation<T, TReturn>(\n // Use \"arguments\" here for better compatibility and smaller bundle size\n // Itentionally casting \"arguments\" to an array for the type of func.apply\n thr.apply(this.s, arguments as any as [any]),\n );\n },\n } satisfies AsyncFromSyncIterator<T, TReturn, TNext>;\n\n function AsyncFromSyncIteratorContinuation<T, TReturn>(r: any) {\n // This step is _before_ calling AsyncFromSyncIteratorContinuation in the spec.\n if (Object(r) !== r) {\n return Promise.reject(new TypeError(r + \" is not an object.\"));\n }\n\n var done = r.done;\n return Promise.resolve(r.value).then<IteratorResult<T, TReturn>>(\n function (value) {\n return { value: value, done: done };\n },\n );\n }\n\n return new AsyncFromSyncIterator(s);\n}\n"],"mappings":";;;;;;AAKe,SAASA,cAAcA,CACpCC,QAAwC,EACxC;EACA,IAAIC,MAA8C;IAChDC,KAAkE;IAClEC,IAAuD;IACvDC,KAAK,GAAG,CAAC;EAEX,IAAI,OAAOC,MAAM,KAAK,WAAW,EAAE;IACjCH,KAAK,GAAGG,MAAM,CAACC,aAAa;IAC5BH,IAAI,GAAGE,MAAM,CAACE,QAAQ;EACxB;EAEA,OAAOH,KAAK,EAAE,EAAE;IAGd,IAAIF,KAAK,IAAI,CAACD,MAAM,GAAID,QAAQ,CAASE,KAAK,CAAC,KAAK,IAAI,EAAE;MACxD,OAAQD,MAAM,CAAwBO,IAAI,CAACR,QAA4B,CAAC;IAC1E;IAEA,IAAIG,IAAI,IAAI,CAACF,MAAM,GAAID,QAAQ,CAASG,IAAI,CAAC,KAAK,IAAI,EAAE;MACtD,OAAO,IAAIM,qBAAqB,CAC7BR,MAAM,CAAuBO,IAAI,CAACR,QAAuB,CAC5D,CAAC;IACH;IAEAE,KAAK,GAAG,iBAAiB;IACzBC,IAAI,GAAG,YAAY;EACrB;EAEA,MAAM,IAAIO,SAAS,CAAC,8BAA8B,CAAC;AACrD;AAoBA,SAASD,qBAAqBA,CAAsCE,CAAM,EAAE;EAE1EF,qBAAqB,GAAG,SAAAA,CAEtBE,CAAc,EACd;IACA,IAAI,CAACA,CAAC,GAAGA,CAAC;IACV,IAAI,CAACC,CAAC,GAAGD,CAAC,CAACE,IAAI;EACjB,CAAC;EACDJ,qBAAqB,CAACK,SAAS,GAAG;IAEbH,CAAC,EAAE,IAAW;IACLC,CAAC,EAAE,IAAW;IAC1CC,IAAI,EAAE,SAAAA,CAAA,EAAY;MAChB,OAAOE,iCAAiC,CAGtC,IAAI,CAACH,CAAC,CAACI,KAAK,CAAC,IAAI,CAACL,CAAC,EAAEM,SAAoC,CAC3D,CAAC;IACH,CAAC;IACDC,MAAM,EAAE,SAAAA,CAAUC,KAAK,EAAE;MACvB,IAAIC,GAAG,GAAG,IAAI,CAACT,CAAC,CAACO,MAAM;MACvB,IAAIE,GAAG,KAAKC,SAAS,EAAE;QACrB,OAAOC,OAAO,CAACC,OAAO,CAAgC;UAGpDJ,KAAK,EAAEA,KAAgB;UACvBK,IAAI,EAAE;QACR,CAAC,CAAC;MACJ;MACA,OAAOT,iCAAiC,CACtCK,GAAG,CAACJ,KAAK,CACP,IAAI,CAACL,CAAC,EAGNM,SACF,CACF,CAAC;IACH,CAAC;IACDQ,KAAK,EAAE,SAAAA,CAAUC,UAAgB,EAAE;MACjC,IAAIC,GAAG,GAAG,IAAI,CAAChB,CAAC,CAACO,MAAM;MACvB,IAAIS,GAAG,KAAKN,SAAS,EAAE;QAErB,OAAOC,OAAO,CAACM,MAAM,CAACF,UAAU,CAAC;MACnC;MACA,OAAOX,iCAAiC,CAGtCY,GAAG,CAACX,KAAK,CAAC,IAAI,CAACL,CAAC,EAAEM,SAAyB,CAC7C,CAAC;IACH;EACF,CAAoD;EAEpD,SAASF,iCAAiCA,CAAac,CAAM,EAAE;IAE7D,IAAIC,MAAM,CAACD,CAAC,CAAC,KAAKA,CAAC,EAAE;MACnB,OAAOP,OAAO,CAACM,MAAM,CAAC,IAAIlB,SAAS,CAACmB,CAAC,GAAG,oBAAoB,CAAC,CAAC;IAChE;IAEA,IAAIL,IAAI,GAAGK,CAAC,CAACL,IAAI;IACjB,OAAOF,OAAO,CAACC,OAAO,CAACM,CAAC,CAACV,KAAK,CAAC,CAACY,IAAI,CAClC,UAAUZ,KAAK,EAAE;MACf,OAAO;QAAEA,KAAK,EAAEA,KAAK;QAAEK,IAAI,EAAEA;MAAK,CAAC;IACrC,CACF,CAAC;EACH;EAEA,OAAO,IAAIf,qBAAqB,CAACE,CAAC,CAAC;AACrC","ignoreList":[]}