"use strict"; var __defProp = Object.defineProperty; var __getOwnPropDesc = Object.getOwnPropertyDescriptor; var __getOwnPropNames = Object.getOwnPropertyNames; var __hasOwnProp = Object.prototype.hasOwnProperty; var __defNormalProp = (obj, key, value) => key in obj ? __defProp(obj, key, { enumerable: true, configurable: true, writable: true, value }) : obj[key] = value; var __name = (target, value) => __defProp(target, "name", { value, configurable: true }); var __export = (target, all) => { for (var name in all) __defProp(target, name, { get: all[name], enumerable: true }); }; var __copyProps = (to, from, except, desc) => { if (from && typeof from === "object" || typeof from === "function") { for (let key of __getOwnPropNames(from)) if (!__hasOwnProp.call(to, key) && key !== except) __defProp(to, key, { get: () => from[key], enumerable: !(desc = __getOwnPropDesc(from, key)) || desc.enumerable }); } return to; }; var __toCommonJS = (mod) => __copyProps(__defProp({}, "__esModule", { value: true }), mod); var __publicField = (obj, key, value) => { __defNormalProp(obj, typeof key !== "symbol" ? key + "" : key, value); return value; }; // src/index.ts var src_exports = {}; __export(src_exports, { AsyncQueue: () => AsyncQueue }); module.exports = __toCommonJS(src_exports); // src/lib/AsyncQueue.ts var AsyncQueue = class { constructor() { __publicField(this, "promises", []); } get remaining() { return this.promises.length; } wait() { const next = this.promises.length ? this.promises[this.promises.length - 1].promise : Promise.resolve(); let resolve; const promise = new Promise((res) => { resolve = res; }); this.promises.push({ resolve, promise }); return next; } shift() { const deferred = this.promises.shift(); if (typeof deferred !== "undefined") deferred.resolve(); } }; // Annotate the CommonJS export names for ESM import in node: 0 && (module.exports = { AsyncQueue }); //# sourceMappingURL=index.js.map