@subsquid/util-internal - npm Package Compare versions

Comparing version 3.3.0-portal-api.fff2e3 to 3.3.0

lib/async.d.ts

@@ -12,2 +12,3 @@ export interface Future<T> {
 export declare class AsyncQueue<T> {
+    private maxsize;
     private buf;
@@ -17,3 +18,3 @@ private pos;
     private closed;
-    private putFuture?;
+    private putFutures;
     private takeFuture?;
@@ -24,2 +25,3 @@ private closeListeners?;
     put(val: T): Promise<void>;
+    private enlargeBuffer;
     forcePut(val: T): void;
@@ -29,10 +31,10 @@ tryPut(val: T): void;
     peek(): T | undefined;
-    wait(): Promise<void>;
     close(): void;
     addCloseListener(cb: () => void): void;
+    removeCloseListener(cb: () => void): void;
     iterate(): AsyncIterable<T>;
 }
-export declare function concurrentMap<T, R>(concurrency: number, stream: AsyncIterable<T>, f: (val: T) => Promise<R>): AsyncIterable<R>;
+export declare function concurrentMap<T, R>(concurrency: number, stream: AsyncIterable<T> | Iterable<T>, f: (val: T) => Promise<R>): AsyncIterable<R>;
 export declare function concurrentWriter<T>(watermark: number, cb: (write: (val: T) => Promise<void>) => Promise<void>): AsyncIterable<T>;
 export declare function safeCall(cb: () => void): void;
 //# sourceMappingURL=async.d.ts.map

lib/async.d.ts.map

@@ -1,1 +0,1 @@
-{"version":3,"file":"async.d.ts","sourceRoot":"","sources":["../src/async.ts"],"names":[],"mappings":"AAKA,MAAM,WAAW,MAAM,CAAC,CAAC;IACrB,OAAO,EAAE,CAAC,GAAG,EAAE,CAAC,KAAK,IAAI,CAAA;IACzB,MAAM,EAAE,CAAC,GAAG,EAAE,KAAK,KAAK,IAAI,CAAA;IAC5B,OAAO,EAAE,MAAM,OAAO,CAAC,CAAC,CAAC,CAAA;CAC5B;AAGD,wBAAgB,YAAY,CAAC,CAAC,KAAK,MAAM,CAAC,CAAC,CAAC,CAU3C;AAGD,qBAAa,gBAAiB,SAAQ,KAAK;;IAKvC,IAAI,IAAI,IAAI,MAAM,CAEjB;CACJ;AAGD,qBAAa,UAAU,CAAC,CAAC;IACrB,OAAO,CAAC,GAAG,CAAmB;IAC9B,OAAO,CAAC,GAAG,CAAI;IACf,OAAO,CAAC,IAAI,CAAI;IAChB,OAAO,CAAC,MAAM,CAAQ;IACtB,OAAO,CAAC,SAAS,CAAC,CAAc;IAChC,OAAO,CAAC,UAAU,CAAC,CAAuB;IAC1C,OAAO,CAAC,cAAc,CAAC,CAAgB;gBAE3B,OAAO,EAAE,MAAM;IAK3B,QAAQ,IAAI,OAAO;IAIb,GAAG,CAAC,GAAG,EAAE,CAAC,GAAG,OAAO,CAAC,IAAI,CAAC;IAkBhC,QAAQ,CAAC,GAAG,EAAE,CAAC,GAAG,IAAI;IAatB,MAAM,CAAC,GAAG,EAAE,CAAC,GAAG,IAAI;IAId,IAAI,IAAI,OAAO,CAAC,CAAC,GAAG,SAAS,CAAC;IAoBpC,IAAI,IAAI,CAAC,GAAG,SAAS;IAIf,IAAI,IAAI,OAAO,CAAC,IAAI,CAAC;IAQ3B,KAAK,IAAI,IAAI;IAkBb,gBAAgB,CAAC,EAAE,EAAE,MAAM,IAAI,GAAG,IAAI;IAS/B,OAAO,IAAI,aAAa,CAAC,CAAC,CAAC;CAWrC;AAGD,wBAAuB,aAAa,CAAC,CAAC,EAAE,CAAC,EACrC,WAAW,EAAE,MAAM,EACnB,MAAM,EAAE,aAAa,CAAC,CAAC,CAAC,EACxB,CAAC,EAAE,CAAC,GAAG,EAAE,CAAC,KAAK,OAAO,CAAC,CAAC,CAAC,GAC1B,aAAa,CAAC,CAAC,CAAC,CAuBlB;AAGD,wBAAuB,gBAAgB,CAAC,CAAC,EACrC,SAAS,EAAE,MAAM,EACjB,EAAE,EAAE,CAAC,KAAK,EAAE,CAAC,GAAG,EAAE,CAAC,KAAK,OAAO,CAAC,IAAI,CAAC,KAAK,OAAO,CAAC,IAAI,CAAC,GACxD,aAAa,CAAC,CAAC,CAAC,CAkBlB;AAGD,wBAAgB,QAAQ,CAAC,EAAE,EAAE,MAAM,IAAI,GAAG,IAAI,CAM7C"}
+{"version":3,"file":"async.d.ts","sourceRoot":"","sources":["../src/async.ts"],"names":[],"mappings":"AAKA,MAAM,WAAW,MAAM,CAAC,CAAC;IACrB,OAAO,EAAE,CAAC,GAAG,EAAE,CAAC,KAAK,IAAI,CAAA;IACzB,MAAM,EAAE,CAAC,GAAG,EAAE,KAAK,KAAK,IAAI,CAAA;IAC5B,OAAO,EAAE,MAAM,OAAO,CAAC,CAAC,CAAC,CAAA;CAC5B;AAGD,wBAAgB,YAAY,CAAC,CAAC,KAAK,MAAM,CAAC,CAAC,CAAC,CAU3C;AAGD,qBAAa,gBAAiB,SAAQ,KAAK;;IAKvC,IAAI,IAAI,IAAI,MAAM,CAEjB;CACJ;AAGD,qBAAa,UAAU,CAAC,CAAC;IAST,OAAO,CAAC,OAAO;IAR3B,OAAO,CAAC,GAAG,CAAmB;IAC9B,OAAO,CAAC,GAAG,CAAI;IACf,OAAO,CAAC,IAAI,CAAI;IAChB,OAAO,CAAC,MAAM,CAAQ;IACtB,OAAO,CAAC,UAAU,CAAqB;IACvC,OAAO,CAAC,UAAU,CAAC,CAAuB;IAC1C,OAAO,CAAC,cAAc,CAAC,CAAgB;gBAEnB,OAAO,EAAE,MAAM;IAKnC,QAAQ,IAAI,OAAO;IAIb,GAAG,CAAC,GAAG,EAAE,CAAC,GAAG,OAAO,CAAC,IAAI,CAAC;IAmBhC,OAAO,CAAC,aAAa;IAUrB,QAAQ,CAAC,GAAG,EAAE,CAAC,GAAG,IAAI;IAatB,MAAM,CAAC,GAAG,EAAE,CAAC,GAAG,IAAI;IAId,IAAI,IAAI,OAAO,CAAC,CAAC,GAAG,SAAS,CAAC;IAsBpC,IAAI,IAAI,CAAC,GAAG,SAAS;IAIrB,KAAK,IAAI,IAAI;IAqBb,gBAAgB,CAAC,EAAE,EAAE,MAAM,IAAI,GAAG,IAAI;IAStC,mBAAmB,CAAC,EAAE,EAAE,MAAM,IAAI,GAAG,IAAI;IAOlC,OAAO,IAAI,aAAa,CAAC,CAAC,CAAC;CAWrC;AAGD,wBAAuB,aAAa,CAAC,CAAC,EAAE,CAAC,EACrC,WAAW,EAAE,MAAM,EACnB,MAAM,EAAE,aAAa,CAAC,CAAC,CAAC,GAAG,QAAQ,CAAC,CAAC,CAAC,EACtC,CAAC,EAAE,CAAC,GAAG,EAAE,CAAC,KAAK,OAAO,CAAC,CAAC,CAAC,GAC1B,aAAa,CAAC,CAAC,CAAC,CA8BlB;AAGD,wBAAuB,gBAAgB,CAAC,CAAC,EACrC,SAAS,EAAE,MAAM,EACjB,EAAE,EAAE,CAAC,KAAK,EAAE,CAAC,GAAG,EAAE,CAAC,KAAK,OAAO,CAAC,IAAI,CAAC,KAAK,OAAO,CAAC,IAAI,CAAC,GACxD,aAAa,CAAC,CAAC,CAAC,CAkBlB;AAGD,wBAAgB,QAAQ,CAAC,EAAE,EAAE,MAAM,IAAI,GAAG,IAAI,CAM7C"}

lib/async.js

@@ -29,3 +29,7 @@ "use strict";
 Object.defineProperty(exports, "__esModule", { value: true });
-exports.safeCall = exports.concurrentWriter = exports.concurrentMap = exports.AsyncQueue = exports.ClosedQueueError = exports.createFuture = void 0;
+exports.AsyncQueue = exports.ClosedQueueError = void 0;
+exports.createFuture = createFuture;
+exports.concurrentMap = concurrentMap;
+exports.concurrentWriter = concurrentWriter;
+exports.safeCall = safeCall;
 const assert_1 = __importDefault(require("assert"));
@@ -45,3 +49,2 @@ const process = __importStar(require("process"));
 }
-exports.createFuture = createFuture;
 class ClosedQueueError extends Error {
@@ -58,5 +61,7 @@ constructor() {
     constructor(maxsize) {
+        this.maxsize = maxsize;
         this.pos = 0;
         this.size = 0;
         this.closed = false;
+        this.putFutures = [];
         (0, assert_1.default)(maxsize >= 1);
@@ -71,3 +76,2 @@ this.buf = new Array(maxsize);
             throw new ClosedQueueError();
-        (0, assert_1.default)(this.size < this.buf.length && this.putFuture == null, 'concurrent puts are not allowed');
         if (this.takeFuture) {
@@ -78,10 +82,23 @@ this.takeFuture.resolve(val);
         else {
+            if (this.size == this.buf.length) {
+                this.enlargeBuffer();
+            }
             this.buf[(this.pos + this.size) % this.buf.length] = val;
             this.size += 1;
-            if (this.size == this.buf.length) {
-                this.putFuture = createFuture();
-                await this.putFuture.promise();
+            if (this.size >= this.maxsize) {
+                let fut = createFuture();
+                this.putFutures.push(fut);
+                await fut.promise();
             }
         }
     }
+    enlargeBuffer() {
+        let len = this.buf.length + 1;
+        for (let i = this.size - this.pos; i < this.size; i++) {
+            let o = this.pos + i;
+            this.buf[o % len] = this.buf[o % this.size];
+        }
+        this.buf[this.size % len] = undefined;
+        (0, assert_1.default)(this.buf.length === len);
+    }
     forcePut(val) {
@@ -111,5 +128,7 @@ if (this.closed)
             this.size -= 1;
-            if (this.putFuture) {
-                this.putFuture.resolve();
-                this.putFuture = undefined;
+            if (this.size < this.maxsize) {
+                for (let fut of this.putFutures) {
+                    fut.resolve();
+                }
+                this.putFutures.length = 0;
             }
@@ -130,17 +149,8 @@ return val;
     }
-    async wait() {
-        if (this.closed)
-            throw new ClosedQueueError();
-        if (this.size < this.buf.length)
-            return;
-        (0, assert_1.default)(this.putFuture == null, 'concurrent puts and waits are not allowed');
-        this.putFuture = createFuture();
-        await this.putFuture.promise();
-    }
     close() {
         this.closed = true;
-        if (this.putFuture) {
-            this.putFuture.reject(new ClosedQueueError());
-            this.putFuture = undefined;
+        for (let fut of this.putFutures) {
+            fut.reject(new ClosedQueueError());
         }
+        this.putFutures.length = 0;
         if (this.takeFuture) {
@@ -167,2 +177,10 @@ this.takeFuture.resolve(undefined);
     }
+    removeCloseListener(cb) {
+        if (this.closeListeners == null)
+            return;
+        let index = this.closeListeners.indexOf(cb);
+        if (index < 0)
+            return;
+        this.closeListeners.splice(index, 1);
+    }
     async *iterate() {
@@ -184,2 +202,8 @@ try {
 async function* concurrentMap(concurrency, stream, f) {
+    if (concurrency == 0) {
+        for await (let val of stream) {
+            yield await f(val);
+        }
+        return;
+    }
     let queue = new AsyncQueue(concurrency);
@@ -202,3 +226,2 @@ async function map() {
 }
-exports.concurrentMap = concurrentMap;
 async function* concurrentWriter(watermark, cb) {
@@ -218,3 +241,2 @@ (0, assert_1.default)(watermark >= 1);
 }
-exports.concurrentWriter = concurrentWriter;
 function safeCall(cb) {
@@ -228,3 +250,2 @@ try {
 }
-exports.safeCall = safeCall;
 //# sourceMappingURL=async.js.map

lib/async.js.map

@@ -1,1 +0,1 @@
-{"version":3,"file":"async.js","sourceRoot":"","sources":["../src/async.ts"],"names":[],"mappings":";;;;;;;;;;;;;;;;;;;;;;;;;;;;;AAAA,oDAA2B;AAC3B,iDAAkC;AAClC,iCAAiD;AAUjD,SAAgB,YAAY;IACxB,IAAI,MAA6B,CAAA;IACjC,IAAI,OAAO,GAAG,IAAI,OAAO,CAAI,CAAC,OAAO,EAAE,MAAM,EAAE,EAAE;QAC7C,MAAM,GAAG;YACL,OAAO;YACP,MAAM;YACN,OAAO,EAAE,GAAG,EAAE,CAAC,OAAO;SACzB,CAAA;IACL,CAAC,CAAC,CAAA;IACF,OAAO,IAAA,oBAAa,EAAC,MAAM,CAAC,CAAA;AAChC,CAAC;AAVD,oCAUC;AAGD,MAAa,gBAAiB,SAAQ,KAAK;IACvC;QACI,KAAK,CAAC,6CAA6C,CAAC,CAAA;IACxD,CAAC;IAED,IAAI,IAAI;QACJ,OAAO,qBAAqB,CAAA;IAChC,CAAC;CACJ;AARD,4CAQC;AAGD,MAAa,UAAU;IASnB,YAAY,OAAe;QAPnB,QAAG,GAAG,CAAC,CAAA;QACP,SAAI,GAAG,CAAC,CAAA;QACR,WAAM,GAAG,KAAK,CAAA;QAMlB,IAAA,gBAAM,EAAC,OAAO,IAAI,CAAC,CAAC,CAAA;QACpB,IAAI,CAAC,GAAG,GAAG,IAAI,KAAK,CAAC,OAAO,CAAC,CAAA;IACjC,CAAC;IAED,QAAQ;QACJ,OAAO,IAAI,CAAC,MAAM,CAAA;IACtB,CAAC;IAED,KAAK,CAAC,GAAG,CAAC,GAAM;QACZ,IAAI,IAAI,CAAC,MAAM;YAAE,MAAM,IAAI,gBAAgB,EAAE,CAAA;QAE7C,IAAA,gBAAM,EAAC,IAAI,CAAC,IAAI,GAAG,IAAI,CAAC,GAAG,CAAC,MAAM,IAAI,IAAI,CAAC,SAAS,IAAI,IAAI,EAAE,iCAAiC,CAAC,CAAA;QAEhG,IAAI,IAAI,CAAC,UAAU,EAAE,CAAC;YAClB,IAAI,CAAC,UAAU,CAAC,OAAO,CAAC,GAAG,CAAC,CAAA;YAC5B,IAAI,CAAC,UAAU,GAAG,SAAS,CAAA;QAC/B,CAAC;aAAM,CAAC;YACJ,IAAI,CAAC,GAAG,CAAC,CAAC,IAAI,CAAC,GAAG,GAAG,IAAI,CAAC,IAAI,CAAC,GAAG,IAAI,CAAC,GAAG,CAAC,MAAM,CAAC,GAAG,GAAG,CAAA;YACxD,IAAI,CAAC,IAAI,IAAI,CAAC,CAAA;YACd,IAAI,IAAI,CAAC,IAAI,IAAI,IAAI,CAAC,GAAG,CAAC,MAAM,EAAE,CAAC;gBAC/B,IAAI,CAAC,SAAS,GAAG,YAAY,EAAE,CAAA;gBAC/B,MAAM,IAAI,CAAC,SAAS,CAAC,OAAO,EAAE,CAAA;YAClC,CAAC;QACL,CAAC;IACL,CAAC;IAED,QAAQ,CAAC,GAAM;QACX,IAAI,IAAI,CAAC,MAAM;YAAE,MAAM,IAAI,gBAAgB,EAAE,CAAA;QAC7C,IAAI,IAAI,CAAC,UAAU,EAAE,CAAC;YAClB,IAAI,CAAC,UAAU,CAAC,OAAO,CAAC,GAAG,CAAC,CAAA;YAC5B,IAAI,CAAC,UAAU,GAAG,SAAS,CAAA;QAC/B,CAAC;aAAM,IAAI,IAAI,CAAC,IAAI,GAAG,IAAI,CAAC,GAAG,CAAC,MAAM,EAAE,CAAC;YACrC,IAAI,CAAC,GAAG,CAAC,CAAC,IAAI,CAAC,GAAG,GAAG,IAAI,CAAC,IAAI,CAAC,GAAG,IAAI,CAAC,GAAG,CAAC,MAAM,CAAC,GAAG,GAAG,CAAA;YACxD,IAAI,CAAC,IAAI,IAAI,CAAC,CAAA;QAClB,CAAC;aAAM,CAAC;YACJ,IAAI,CAAC,GAAG,CAAC,CAAC,IAAI,CAAC,GAAG,GAAG,IAAI,CAAC,IAAI,GAAG,CAAC,CAAC,GAAG,IAAI,CAAC,GAAG,CAAC,MAAM,CAAC,GAAG,GAAG,CAAA;QAChE,CAAC;IACL,CAAC;IAED,MAAM,CAAC,GAAM;QACT,IAAI,CAAC,GAAG,CAAC,GAAG,CAAC,CAAC,KAAK,CAAC,GAAG,CAAC,EAAE,GAAE,CAAC,CAAC,CAAA;IAClC,CAAC;IAED,KAAK,CAAC,IAAI;QACN,IAAI,IAAI,CAAC,IAAI,GAAG,CAAC,EAAE,CAAC;YAChB,IAAI,GAAG,GAAG,IAAI,CAAC,GAAG,CAAC,IAAI,CAAC,GAAG,CAAE,CAAA;YAC7B,IAAI,CAAC,GAAG,CAAC,IAAI,CAAC,GAAG,CAAC,GAAG,SAAS,CAAA;YAC9B,IAAI,CAAC,GAAG,GAAG,CAAC,IAAI,CAAC,GAAG,GAAG,CAAC,CAAC,GAAG,IAAI,CAAC,GAAG,CAAC,MAAM,CAAA;YAC3C,IAAI,CAAC,IAAI,IAAI,CAAC,CAAA;YACd,IAAI,IAAI,CAAC,SAAS,EAAE,CAAC;gBACjB,IAAI,CAAC,SAAS,CAAC,OAAO,EAAE,CAAA;gBACxB,IAAI,CAAC,SAAS,GAAG,SAAS,CAAA;YAC9B,CAAC;YACD,OAAO,GAAG,CAAA;QACd,CAAC;aAAM,IAAI,IAAI,CAAC,MAAM,EAAE,CAAC;YACrB,OAAO,SAAS,CAAA;QACpB,CAAC;aAAM,CAAC;YACJ,IAAA,gBAAM,EAAC,IAAI,CAAC,UAAU,IAAI,IAAI,EAAE,kCAAkC,CAAC,CAAA;YACnE,IAAI,CAAC,UAAU,GAAG,YAAY,EAAE,CAAA;YAChC,OAAO,IAAI,CAAC,UAAU,CAAC,OAAO,EAAE,CAAA;QACpC,CAAC;IACL,CAAC;IAED,IAAI;QACA,OAAO,IAAI,CAAC,GAAG,CAAC,IAAI,CAAC,GAAG,CAAC,CAAA;IAC7B,CAAC;IAED,KAAK,CAAC,IAAI;QACN,IAAI,IAAI,CAAC,MAAM;YAAE,MAAM,IAAI,gBAAgB,EAAE,CAAA;QAC7C,IAAI,IAAI,CAAC,IAAI,GAAG,IAAI,CAAC,GAAG,CAAC,MAAM;YAAE,OAAM;QACvC,IAAA,gBAAM,EAAC,IAAI,CAAC,SAAS,IAAI,IAAI,EAAE,2CAA2C,CAAC,CAAA;QAC3E,IAAI,CAAC,SAAS,GAAG,YAAY,EAAE,CAAA;QAC/B,MAAM,IAAI,CAAC,SAAS,CAAC,OAAO,EAAE,CAAA;IAClC,CAAC;IAED,KAAK;QACD,IAAI,CAAC,MAAM,GAAG,IAAI,CAAA;QAClB,IAAI,IAAI,CAAC,SAAS,EAAE,CAAC;YACjB,IAAI,CAAC,SAAS,CAAC,MAAM,CAAC,IAAI,gBAAgB,EAAE,CAAC,CAAA;YAC7C,IAAI,CAAC,SAAS,GAAG,SAAS,CAAA;QAC9B,CAAC;QACD,IAAI,IAAI,CAAC,UAAU,EAAE,CAAC;YAClB,IAAI,CAAC,UAAU,CAAC,OAAO,CAAC,SAAS,CAAC,CAAA;YAClC,IAAI,CAAC,UAAU,GAAG,SAAS,CAAA;QAC/B,CAAC;QACD,IAAI,IAAI,CAAC,cAAc,EAAE,CAAC;YACtB,KAAK,IAAI,EAAE,IAAI,IAAI,CAAC,cAAc,EAAE,CAAC;gBACjC,QAAQ,CAAC,EAAE,CAAC,CAAA;YAChB,CAAC;YACD,IAAI,CAAC,cAAc,GAAG,SAAS,CAAA;QACnC,CAAC;IACL,CAAC;IAED,gBAAgB,CAAC,EAAc;QAC3B,IAAI,IAAI,CAAC,MAAM;YAAE,OAAO,OAAO,CAAC,QAAQ,CAAC,GAAG,EAAE,CAAC,QAAQ,CAAC,EAAE,CAAC,CAAC,CAAA;QAC5D,IAAI,IAAI,CAAC,cAAc,IAAI,IAAI,EAAE,CAAC;YAC9B,IAAI,CAAC,cAAc,GAAG,CAAC,EAAE,CAAC,CAAA;QAC9B,CAAC;aAAM,CAAC;YACJ,IAAI,CAAC,cAAc,CAAC,IAAI,CAAC,EAAE,CAAC,CAAA;QAChC,CAAC;IACL,CAAC;IAED,KAAK,CAAC,CAAC,OAAO;QACV,IAAI,CAAC;YACD,OAAO,IAAI,EAAE,CAAC;gBACV,IAAI,GAAG,GAAG,MAAM,IAAI,CAAC,IAAI,EAAE,CAAA;gBAC3B,IAAI,GAAG,KAAK,SAAS;oBAAE,OAAM;gBAC7B,MAAM,GAAG,CAAA;YACb,CAAC;QACL,CAAC;gBAAS,CAAC;YACP,IAAI,CAAC,KAAK,EAAE,CAAA;QAChB,CAAC;IACL,CAAC;CACJ;AA3HD,gCA2HC;AAGM,KAAK,SAAS,CAAC,CAAC,aAAa,CAChC,WAAmB,EACnB,MAAwB,EACxB,CAAyB;IAEzB,IAAI,KAAK,GAAG,IAAI,UAAU,CAAwB,WAAW,CAAC,CAAA;IAE9D,KAAK,UAAU,GAAG;QACd,IAAI,KAAK,EAAE,IAAI,GAAG,IAAI,MAAM,EAAE,CAAC;YAC3B,IAAI,OAAO,GAAG,CAAC,CAAC,GAAG,CAAC,CAAA;YACpB,OAAO,CAAC,KAAK,CAAC,GAAG,EAAE,GAAE,CAAC,CAAC,CAAA,CAAC,sCAAsC;YAC9D,MAAM,KAAK,CAAC,GAAG,CAAC,EAAC,OAAO,EAAC,CAAC,CAAA;QAC9B,CAAC;IACL,CAAC;IAED,GAAG,EAAE,CAAC,IAAI,CACN,GAAG,EAAE,CAAC,KAAK,CAAC,KAAK,EAAE,EACnB,GAAG,CAAC,EAAE;QACF,IAAI,OAAO,GAAG,OAAO,CAAC,MAAM,CAAC,GAAG,CAAC,CAAA;QACjC,OAAO,CAAC,KAAK,CAAC,GAAG,EAAE,GAAE,CAAC,CAAC,CAAA,CAAC,sCAAsC;QAC9D,KAAK,CAAC,MAAM,CAAC,EAAC,OAAO,EAAC,CAAC,CAAA;IAC3B,CAAC,CACJ,CAAA;IAED,IAAI,KAAK,EAAE,IAAI,IAAI,IAAI,KAAK,CAAC,OAAO,EAAE,EAAE,CAAC;QACrC,MAAM,MAAM,IAAI,CAAC,OAAO,CAAA;IAC5B,CAAC;AACL,CAAC;AA3BD,sCA2BC;AAGM,KAAK,SAAS,CAAC,CAAC,gBAAgB,CACnC,SAAiB,EACjB,EAAuD;IAEvD,IAAA,gBAAM,EAAC,SAAS,IAAI,CAAC,CAAC,CAAA;IAEtB,IAAI,KAAK,GAAG,IAAI,UAAU,CAAY,SAAS,CAAC,CAAA;IAEhD,EAAE,CAAC,KAAK,CAAC,EAAE,CAAC,KAAK,CAAC,GAAG,CAAC,KAAK,CAAC,CAAC,CAAC,IAAI,CAC9B,GAAG,EAAE,CAAC,KAAK,CAAC,KAAK,EAAE,EACnB,GAAG,CAAC,EAAE;QACF,IAAI,CAAC,KAAK,CAAC,QAAQ,EAAE,EAAE,CAAC;YACpB,KAAK,CAAC,QAAQ,CAAC,IAAA,kBAAW,EAAC,GAAG,CAAC,CAAC,CAAA;QACpC,CAAC;IACL,CAAC,CACJ,CAAA;IAED,IAAI,KAAK,EAAE,IAAI,YAAY,IAAI,KAAK,CAAC,OAAO,EAAE,EAAE,CAAC;QAC7C,IAAI,YAAY,YAAY,KAAK;YAAE,MAAM,YAAY,CAAA;QACrD,MAAM,YAAY,CAAA;IACtB,CAAC;AACL,CAAC;AArBD,4CAqBC;AAGD,SAAgB,QAAQ,CAAC,EAAc;IACnC,IAAI,CAAC;QACD,EAAE,EAAE,CAAA;IACR,CAAC;IAAC,OAAM,GAAQ,EAAE,CAAC;QACf,OAAO,CAAC,MAAM,CAAC,GAAG,CAAC,CAAA;IACvB,CAAC;AACL,CAAC;AAND,4BAMC"}
+{"version":3,"file":"async.js","sourceRoot":"","sources":["../src/async.ts"],"names":[],"mappings":";;;;;;;;;;;;;;;;;;;;;;;;;;;;;AAYA,oCAUC;AA2JD,sCAkCC;AAGD,4CAqBC;AAGD,4BAMC;AApPD,oDAA2B;AAC3B,iDAAkC;AAClC,iCAAiD;AAUjD,SAAgB,YAAY;IACxB,IAAI,MAA6B,CAAA;IACjC,IAAI,OAAO,GAAG,IAAI,OAAO,CAAI,CAAC,OAAO,EAAE,MAAM,EAAE,EAAE;QAC7C,MAAM,GAAG;YACL,OAAO;YACP,MAAM;YACN,OAAO,EAAE,GAAG,EAAE,CAAC,OAAO;SACzB,CAAA;IACL,CAAC,CAAC,CAAA;IACF,OAAO,IAAA,oBAAa,EAAC,MAAM,CAAC,CAAA;AAChC,CAAC;AAGD,MAAa,gBAAiB,SAAQ,KAAK;IACvC;QACI,KAAK,CAAC,6CAA6C,CAAC,CAAA;IACxD,CAAC;IAED,IAAI,IAAI;QACJ,OAAO,qBAAqB,CAAA;IAChC,CAAC;CACJ;AARD,4CAQC;AAGD,MAAa,UAAU;IASnB,YAAoB,OAAe;QAAf,YAAO,GAAP,OAAO,CAAQ;QAP3B,QAAG,GAAG,CAAC,CAAA;QACP,SAAI,GAAG,CAAC,CAAA;QACR,WAAM,GAAG,KAAK,CAAA;QACd,eAAU,GAAmB,EAAE,CAAA;QAKnC,IAAA,gBAAM,EAAC,OAAO,IAAI,CAAC,CAAC,CAAA;QACpB,IAAI,CAAC,GAAG,GAAG,IAAI,KAAK,CAAC,OAAO,CAAC,CAAA;IACjC,CAAC;IAED,QAAQ;QACJ,OAAO,IAAI,CAAC,MAAM,CAAA;IACtB,CAAC;IAED,KAAK,CAAC,GAAG,CAAC,GAAM;QACZ,IAAI,IAAI,CAAC,MAAM;YAAE,MAAM,IAAI,gBAAgB,EAAE,CAAA;QAC7C,IAAI,IAAI,CAAC,UAAU,EAAE,CAAC;YAClB,IAAI,CAAC,UAAU,CAAC,OAAO,CAAC,GAAG,CAAC,CAAA;YAC5B,IAAI,CAAC,UAAU,GAAG,SAAS,CAAA;QAC/B,CAAC;aAAM,CAAC;YACJ,IAAI,IAAI,CAAC,IAAI,IAAI,IAAI,CAAC,GAAG,CAAC,MAAM,EAAE,CAAC;gBAC/B,IAAI,CAAC,aAAa,EAAE,CAAA;YACxB,CAAC;YACD,IAAI,CAAC,GAAG,CAAC,CAAC,IAAI,CAAC,GAAG,GAAG,IAAI,CAAC,IAAI,CAAC,GAAG,IAAI,CAAC,GAAG,CAAC,MAAM,CAAC,GAAG,GAAG,CAAA;YACxD,IAAI,CAAC,IAAI,IAAI,CAAC,CAAA;YACd,IAAI,IAAI,CAAC,IAAI,IAAI,IAAI,CAAC,OAAO,EAAE,CAAC;gBAC5B,IAAI,GAAG,GAAG,YAAY,EAAQ,CAAA;gBAC9B,IAAI,CAAC,UAAU,CAAC,IAAI,CAAC,GAAG,CAAC,CAAA;gBACzB,MAAM,GAAG,CAAC,OAAO,EAAE,CAAA;YACvB,CAAC;QACL,CAAC;IACL,CAAC;IAEO,aAAa;QACjB,IAAI,GAAG,GAAG,IAAI,CAAC,GAAG,CAAC,MAAM,GAAG,CAAC,CAAA;QAC7B,KAAK,IAAI,CAAC,GAAG,IAAI,CAAC,IAAI,GAAG,IAAI,CAAC,GAAG,EAAE,CAAC,GAAG,IAAI,CAAC,IAAI,EAAE,CAAC,EAAE,EAAE,CAAC;YACpD,IAAI,CAAC,GAAG,IAAI,CAAC,GAAG,GAAG,CAAC,CAAA;YACpB,IAAI,CAAC,GAAG,CAAC,CAAC,GAAG,GAAG,CAAC,GAAG,IAAI,CAAC,GAAG,CAAC,CAAC,GAAG,IAAI,CAAC,IAAI,CAAC,CAAA;QAC/C,CAAC;QACD,IAAI,CAAC,GAAG,CAAC,IAAI,CAAC,IAAI,GAAG,GAAG,CAAC,GAAG,SAAS,CAAA;QACrC,IAAA,gBAAM,EAAC,IAAI,CAAC,GAAG,CAAC,MAAM,KAAK,GAAG,CAAC,CAAA;IACnC,CAAC;IAED,QAAQ,CAAC,GAAM;QACX,IAAI,IAAI,CAAC,MAAM;YAAE,MAAM,IAAI,gBAAgB,EAAE,CAAA;QAC7C,IAAI,IAAI,CAAC,UAAU,EAAE,CAAC;YAClB,IAAI,CAAC,UAAU,CAAC,OAAO,CAAC,GAAG,CAAC,CAAA;YAC5B,IAAI,CAAC,UAAU,GAAG,SAAS,CAAA;QAC/B,CAAC;aAAM,IAAI,IAAI,CAAC,IAAI,GAAG,IAAI,CAAC,GAAG,CAAC,MAAM,EAAE,CAAC;YACrC,IAAI,CAAC,GAAG,CAAC,CAAC,IAAI,CAAC,GAAG,GAAG,IAAI,CAAC,IAAI,CAAC,GAAG,IAAI,CAAC,GAAG,CAAC,MAAM,CAAC,GAAG,GAAG,CAAA;YACxD,IAAI,CAAC,IAAI,IAAI,CAAC,CAAA;QAClB,CAAC;aAAM,CAAC;YACJ,IAAI,CAAC,GAAG,CAAC,CAAC,IAAI,CAAC,GAAG,GAAG,IAAI,CAAC,IAAI,GAAG,CAAC,CAAC,GAAG,IAAI,CAAC,GAAG,CAAC,MAAM,CAAC,GAAG,GAAG,CAAA;QAChE,CAAC;IACL,CAAC;IAED,MAAM,CAAC,GAAM;QACT,IAAI,CAAC,GAAG,CAAC,GAAG,CAAC,CAAC,KAAK,CAAC,GAAG,CAAC,EAAE,GAAE,CAAC,CAAC,CAAA;IAClC,CAAC;IAED,KAAK,CAAC,IAAI;QACN,IAAI,IAAI,CAAC,IAAI,GAAG,CAAC,EAAE,CAAC;YAChB,IAAI,GAAG,GAAG,IAAI,CAAC,GAAG,CAAC,IAAI,CAAC,GAAG,CAAE,CAAA;YAC7B,IAAI,CAAC,GAAG,CAAC,IAAI,CAAC,GAAG,CAAC,GAAG,SAAS,CAAA;YAC9B,IAAI,CAAC,GAAG,GAAG,CAAC,IAAI,CAAC,GAAG,GAAG,CAAC,CAAC,GAAG,IAAI,CAAC,GAAG,CAAC,MAAM,CAAA;YAC3C,IAAI,CAAC,IAAI,IAAI,CAAC,CAAA;YACd,IAAI,IAAI,CAAC,IAAI,GAAG,IAAI,CAAC,OAAO,EAAE,CAAC;gBAC3B,KAAK,IAAI,GAAG,IAAI,IAAI,CAAC,UAAU,EAAE,CAAC;oBAC9B,GAAG,CAAC,OAAO,EAAE,CAAA;gBACjB,CAAC;gBACD,IAAI,CAAC,UAAU,CAAC,MAAM,GAAG,CAAC,CAAA;YAC9B,CAAC;YACD,OAAO,GAAG,CAAA;QACd,CAAC;aAAM,IAAI,IAAI,CAAC,MAAM,EAAE,CAAC;YACrB,OAAO,SAAS,CAAA;QACpB,CAAC;aAAM,CAAC;YACJ,IAAA,gBAAM,EAAC,IAAI,CAAC,UAAU,IAAI,IAAI,EAAE,kCAAkC,CAAC,CAAA;YACnE,IAAI,CAAC,UAAU,GAAG,YAAY,EAAE,CAAA;YAChC,OAAO,IAAI,CAAC,UAAU,CAAC,OAAO,EAAE,CAAA;QACpC,CAAC;IACL,CAAC;IAED,IAAI;QACA,OAAO,IAAI,CAAC,GAAG,CAAC,IAAI,CAAC,GAAG,CAAC,CAAA;IAC7B,CAAC;IAED,KAAK;QACD,IAAI,CAAC,MAAM,GAAG,IAAI,CAAA;QAElB,KAAK,IAAI,GAAG,IAAI,IAAI,CAAC,UAAU,EAAE,CAAC;YAC9B,GAAG,CAAC,MAAM,CAAC,IAAI,gBAAgB,EAAE,CAAC,CAAA;QACtC,CAAC;QACD,IAAI,CAAC,UAAU,CAAC,MAAM,GAAG,CAAC,CAAA;QAE1B,IAAI,IAAI,CAAC,UAAU,EAAE,CAAC;YAClB,IAAI,CAAC,UAAU,CAAC,OAAO,CAAC,SAAS,CAAC,CAAA;YAClC,IAAI,CAAC,UAAU,GAAG,SAAS,CAAA;QAC/B,CAAC;QAED,IAAI,IAAI,CAAC,cAAc,EAAE,CAAC;YACtB,KAAK,IAAI,EAAE,IAAI,IAAI,CAAC,cAAc,EAAE,CAAC;gBACjC,QAAQ,CAAC,EAAE,CAAC,CAAA;YAChB,CAAC;YACD,IAAI,CAAC,cAAc,GAAG,SAAS,CAAA;QACnC,CAAC;IACL,CAAC;IAED,gBAAgB,CAAC,EAAc;QAC3B,IAAI,IAAI,CAAC,MAAM;YAAE,OAAO,OAAO,CAAC,QAAQ,CAAC,GAAG,EAAE,CAAC,QAAQ,CAAC,EAAE,CAAC,CAAC,CAAA;QAC5D,IAAI,IAAI,CAAC,cAAc,IAAI,IAAI,EAAE,CAAC;YAC9B,IAAI,CAAC,cAAc,GAAG,CAAC,EAAE,CAAC,CAAA;QAC9B,CAAC;aAAM,CAAC;YACJ,IAAI,CAAC,cAAc,CAAC,IAAI,CAAC,EAAE,CAAC,CAAA;QAChC,CAAC;IACL,CAAC;IAED,mBAAmB,CAAC,EAAc;QAC9B,IAAI,IAAI,CAAC,cAAc,IAAI,IAAI;YAAE,OAAM;QACvC,IAAI,KAAK,GAAG,IAAI,CAAC,cAAc,CAAC,OAAO,CAAC,EAAE,CAAC,CAAA;QAC3C,IAAI,KAAK,GAAG,CAAC;YAAE,OAAM;QACrB,IAAI,CAAC,cAAc,CAAC,MAAM,CAAC,KAAK,EAAE,CAAC,CAAC,CAAA;IACxC,CAAC;IAED,KAAK,CAAC,CAAC,OAAO;QACV,IAAI,CAAC;YACD,OAAO,IAAI,EAAE,CAAC;gBACV,IAAI,GAAG,GAAG,MAAM,IAAI,CAAC,IAAI,EAAE,CAAA;gBAC3B,IAAI,GAAG,KAAK,SAAS;oBAAE,OAAM;gBAC7B,MAAM,GAAG,CAAA;YACb,CAAC;QACL,CAAC;gBAAS,CAAC;YACP,IAAI,CAAC,KAAK,EAAE,CAAA;QAChB,CAAC;IACL,CAAC;CACJ;AA1ID,gCA0IC;AAGM,KAAK,SAAS,CAAC,CAAC,aAAa,CAChC,WAAmB,EACnB,MAAsC,EACtC,CAAyB;IAEzB,IAAI,WAAW,IAAI,CAAC,EAAE,CAAC;QACnB,IAAI,KAAK,EAAE,IAAI,GAAG,IAAI,MAAM,EAAE,CAAC;YAC3B,MAAM,MAAM,CAAC,CAAC,GAAG,CAAC,CAAA;QACtB,CAAC;QACD,OAAM;IACV,CAAC;IAED,IAAI,KAAK,GAAG,IAAI,UAAU,CAAwB,WAAW,CAAC,CAAA;IAE9D,KAAK,UAAU,GAAG;QACd,IAAI,KAAK,EAAE,IAAI,GAAG,IAAI,MAAM,EAAE,CAAC;YAC3B,IAAI,OAAO,GAAG,CAAC,CAAC,GAAG,CAAC,CAAA;YACpB,OAAO,CAAC,KAAK,CAAC,GAAG,EAAE,GAAE,CAAC,CAAC,CAAA,CAAC,sCAAsC;YAC9D,MAAM,KAAK,CAAC,GAAG,CAAC,EAAC,OAAO,EAAC,CAAC,CAAA;QAC9B,CAAC;IACL,CAAC;IAED,GAAG,EAAE,CAAC,IAAI,CACN,GAAG,EAAE,CAAC,KAAK,CAAC,KAAK,EAAE,EACnB,GAAG,CAAC,EAAE;QACF,IAAI,OAAO,GAAG,OAAO,CAAC,MAAM,CAAC,GAAG,CAAC,CAAA;QACjC,OAAO,CAAC,KAAK,CAAC,GAAG,EAAE,GAAE,CAAC,CAAC,CAAA,CAAC,sCAAsC;QAC9D,KAAK,CAAC,MAAM,CAAC,EAAC,OAAO,EAAC,CAAC,CAAA;IAC3B,CAAC,CACJ,CAAA;IAED,IAAI,KAAK,EAAE,IAAI,IAAI,IAAI,KAAK,CAAC,OAAO,EAAE,EAAE,CAAC;QACrC,MAAM,MAAM,IAAI,CAAC,OAAO,CAAA;IAC5B,CAAC;AACL,CAAC;AAGM,KAAK,SAAS,CAAC,CAAC,gBAAgB,CACnC,SAAiB,EACjB,EAAuD;IAEvD,IAAA,gBAAM,EAAC,SAAS,IAAI,CAAC,CAAC,CAAA;IAEtB,IAAI,KAAK,GAAG,IAAI,UAAU,CAAY,SAAS,CAAC,CAAA;IAEhD,EAAE,CAAC,KAAK,CAAC,EAAE,CAAC,KAAK,CAAC,GAAG,CAAC,KAAK,CAAC,CAAC,CAAC,IAAI,CAC9B,GAAG,EAAE,CAAC,KAAK,CAAC,KAAK,EAAE,EACnB,GAAG,CAAC,EAAE;QACF,IAAI,CAAC,KAAK,CAAC,QAAQ,EAAE,EAAE,CAAC;YACpB,KAAK,CAAC,QAAQ,CAAC,IAAA,kBAAW,EAAC,GAAG,CAAC,CAAC,CAAA;QACpC,CAAC;IACL,CAAC,CACJ,CAAA;IAED,IAAI,KAAK,EAAE,IAAI,YAAY,IAAI,KAAK,CAAC,OAAO,EAAE,EAAE,CAAC;QAC7C,IAAI,YAAY,YAAY,KAAK;YAAE,MAAM,YAAY,CAAA;QACrD,MAAM,YAAY,CAAA;IACtB,CAAC;AACL,CAAC;AAGD,SAAgB,QAAQ,CAAC,EAAc;IACnC,IAAI,CAAC;QACD,EAAE,EAAE,CAAA;IACR,CAAC;IAAC,OAAM,GAAQ,EAAE,CAAC;QACf,OAAO,CAAC,MAAM,CAAC,GAAG,CAAC,CAAA;IACvB,CAAC;AACL,CAAC"}

lib/def.js

 "use strict";
 Object.defineProperty(exports, "__esModule", { value: true });
-exports.def = void 0;
+exports.def = def;
 /**
@@ -31,3 +31,2 @@ * Method decorator, which when applied caches the result of the first invocation and returns it
 }
-exports.def = def;
 //# sourceMappingURL=def.js.map

lib/def.js.map

@@ -1,1 +0,1 @@
-{"version":3,"file":"def.js","sourceRoot":"","sources":["../src/def.ts"],"names":[],"mappings":";;;AAAA;;;GAGG;AACH,SAAgB,GAAG,CAAC,KAAU,EAAE,IAAY,EAAE,CAAqB;IAC/D,IAAI,EAAC,KAAK,EAAE,EAAE,EAAE,GAAG,OAAO,EAAC,GAAG,CAAC,CAAA;IAC/B,IAAI,QAAQ,GAAG,MAAM,CAAC,IAAI,GAAG,WAAW,CAAC,CAAA;IACzC,IAAI,SAAS,GAAG,MAAM,CAAC,IAAI,GAAG,YAAY,CAAC,CAAA;IAC3C,IAAI,KAAK,GAAG,MAAM,CAAC,IAAI,GAAG,QAAQ,CAAC,CAAA;IAEnC,IAAI,KAAK,GAAG;QACR,IAAI,IAAI,CAAC,QAAQ,CAAC;YAAE,OAAO,IAAI,CAAC,KAAK,CAAC,CAAA;QACtC,IAAI,IAAI,CAAC,SAAS,CAAC;YAAE,MAAM,IAAI,KAAK,CAAC,2BAA2B,GAAG,IAAI,CAAC,CAAA;QACxE,IAAI,CAAC,SAAS,CAAC,GAAG,IAAI,CAAA;QACtB,IAAI,CAAC;YACD,IAAI,CAAC,KAAK,CAAC,GAAG,EAAE,CAAC,IAAI,CAAC,IAAI,CAAC,CAAA;YAC3B,IAAI,CAAC,QAAQ,CAAC,GAAG,IAAI,CAAA;QACzB,CAAC;gBAAS,CAAC;YACP,IAAI,CAAC,SAAS,CAAC,GAAG,KAAK,CAAA;QAC3B,CAAC;QACD,OAAO,IAAI,CAAC,KAAK,CAAC,CAAA;IACtB,CAAQ,CAAA;IAER,KAAK,CAAC,iBAAiB,GAAG,KAAK,CAAA;IAE/B,OAAO,EAAC,KAAK,EAAE,GAAG,OAAO,EAAC,CAAA;AAC9B,CAAC;AAtBD,kBAsBC"}
+{"version":3,"file":"def.js","sourceRoot":"","sources":["../src/def.ts"],"names":[],"mappings":";;AAIA,kBAsBC;AA1BD;;;GAGG;AACH,SAAgB,GAAG,CAAC,KAAU,EAAE,IAAY,EAAE,CAAqB;IAC/D,IAAI,EAAC,KAAK,EAAE,EAAE,EAAE,GAAG,OAAO,EAAC,GAAG,CAAC,CAAA;IAC/B,IAAI,QAAQ,GAAG,MAAM,CAAC,IAAI,GAAG,WAAW,CAAC,CAAA;IACzC,IAAI,SAAS,GAAG,MAAM,CAAC,IAAI,GAAG,YAAY,CAAC,CAAA;IAC3C,IAAI,KAAK,GAAG,MAAM,CAAC,IAAI,GAAG,QAAQ,CAAC,CAAA;IAEnC,IAAI,KAAK,GAAG;QACR,IAAI,IAAI,CAAC,QAAQ,CAAC;YAAE,OAAO,IAAI,CAAC,KAAK,CAAC,CAAA;QACtC,IAAI,IAAI,CAAC,SAAS,CAAC;YAAE,MAAM,IAAI,KAAK,CAAC,2BAA2B,GAAG,IAAI,CAAC,CAAA;QACxE,IAAI,CAAC,SAAS,CAAC,GAAG,IAAI,CAAA;QACtB,IAAI,CAAC;YACD,IAAI,CAAC,KAAK,CAAC,GAAG,EAAE,CAAC,IAAI,CAAC,IAAI,CAAC,CAAA;YAC3B,IAAI,CAAC,QAAQ,CAAC,GAAG,IAAI,CAAA;QACzB,CAAC;gBAAS,CAAC;YACP,IAAI,CAAC,SAAS,CAAC,GAAG,KAAK,CAAA;QAC3B,CAAC;QACD,OAAO,IAAI,CAAC,KAAK,CAAC,CAAA;IACtB,CAAQ,CAAA;IAER,KAAK,CAAC,iBAAiB,GAAG,KAAK,CAAA;IAE/B,OAAO,EAAC,KAAK,EAAE,GAAG,OAAO,EAAC,CAAA;AAC9B,CAAC"}

lib/io.d.ts

@@ -1,4 +0,3 @@
-/// <reference types="node" />
 import type { Writable } from 'stream';
 export declare function waitDrain(out: Writable): Promise<void>;
 //# sourceMappingURL=io.d.ts.map

lib/io.d.ts.map

@@ -1,1 +0,1 @@
-{"version":3,"file":"io.d.ts","sourceRoot":"","sources":["../src/io.ts"],"names":[],"mappings":";AAAA,OAAO,KAAK,EAAC,QAAQ,EAAC,MAAM,QAAQ,CAAA;AAIpC,wBAAgB,SAAS,CAAC,GAAG,EAAE,QAAQ,GAAG,OAAO,CAAC,IAAI,CAAC,CA2BtD"}
+{"version":3,"file":"io.d.ts","sourceRoot":"","sources":["../src/io.ts"],"names":[],"mappings":"AAAA,OAAO,KAAK,EAAC,QAAQ,EAAC,MAAM,QAAQ,CAAA;AAIpC,wBAAgB,SAAS,CAAC,GAAG,EAAE,QAAQ,GAAG,OAAO,CAAC,IAAI,CAAC,CA2BtD"}

lib/io.js

 "use strict";
 Object.defineProperty(exports, "__esModule", { value: true });
-exports.waitDrain = void 0;
+exports.waitDrain = waitDrain;
 const misc_1 = require("./misc");
@@ -29,3 +29,2 @@ function waitDrain(out) {
 }
-exports.waitDrain = waitDrain;
 //# sourceMappingURL=io.js.map

lib/io.js.map

@@ -1,1 +0,1 @@
-{"version":3,"file":"io.js","sourceRoot":"","sources":["../src/io.ts"],"names":[],"mappings":";;;AACA,iCAAkC;AAGlC,SAAgB,SAAS,CAAC,GAAa;IACnC,OAAO,IAAI,OAAO,CAAC,CAAC,OAAO,EAAE,MAAM,EAAE,EAAE;QACnC,8CAA8C;QAC9C,IAAI,CAAC,GAAG,CAAC,QAAQ,IAAI,GAAG,CAAC,SAAS,IAAI,GAAG,CAAC,OAAO,IAAI,GAAG,CAAC,aAAa,EAAE,CAAC;YACrE,OAAO,MAAM,CAAC,IAAI,KAAK,CAAC,qCAAqC,CAAC,CAAC,CAAA;QACnE,CAAC;QAED,IAAI,CAAC,GAAG,CAAC,iBAAiB;YAAE,OAAO,OAAO,EAAE,CAAA;QAE5C,SAAS,OAAO;YACZ,GAAG,CAAC,cAAc,CAAC,OAAO,EAAE,KAAK,CAAC,CAAA;YAClC,GAAG,CAAC,cAAc,CAAC,OAAO,EAAE,KAAK,CAAC,CAAA;QACtC,CAAC;QAED,SAAS,KAAK;YACV,OAAO,EAAE,CAAA;YACT,OAAO,EAAE,CAAA;QACb,CAAC;QAED,SAAS,KAAK,CAAC,GAAQ;YACnB,OAAO,EAAE,CAAA;YACT,MAAM,CAAC,IAAA,kBAAW,EAAC,GAAG,CAAC,CAAC,CAAA;QAC5B,CAAC;QAED,GAAG,CAAC,EAAE,CAAC,OAAO,EAAE,KAAK,CAAC,CAAA;QACtB,GAAG,CAAC,EAAE,CAAC,OAAO,EAAE,KAAK,CAAC,CAAA;IAC1B,CAAC,CAAC,CAAA;AACN,CAAC;AA3BD,8BA2BC"}
+{"version":3,"file":"io.js","sourceRoot":"","sources":["../src/io.ts"],"names":[],"mappings":";;AAIA,8BA2BC;AA9BD,iCAAkC;AAGlC,SAAgB,SAAS,CAAC,GAAa;IACnC,OAAO,IAAI,OAAO,CAAC,CAAC,OAAO,EAAE,MAAM,EAAE,EAAE;QACnC,8CAA8C;QAC9C,IAAI,CAAC,GAAG,CAAC,QAAQ,IAAI,GAAG,CAAC,SAAS,IAAI,GAAG,CAAC,OAAO,IAAI,GAAG,CAAC,aAAa,EAAE,CAAC;YACrE,OAAO,MAAM,CAAC,IAAI,KAAK,CAAC,qCAAqC,CAAC,CAAC,CAAA;QACnE,CAAC;QAED,IAAI,CAAC,GAAG,CAAC,iBAAiB;YAAE,OAAO,OAAO,EAAE,CAAA;QAE5C,SAAS,OAAO;YACZ,GAAG,CAAC,cAAc,CAAC,OAAO,EAAE,KAAK,CAAC,CAAA;YAClC,GAAG,CAAC,cAAc,CAAC,OAAO,EAAE,KAAK,CAAC,CAAA;QACtC,CAAC;QAED,SAAS,KAAK;YACV,OAAO,EAAE,CAAA;YACT,OAAO,EAAE,CAAA;QACb,CAAC;QAED,SAAS,KAAK,CAAC,GAAQ;YACnB,OAAO,EAAE,CAAA;YACT,MAAM,CAAC,IAAA,kBAAW,EAAC,GAAG,CAAC,CAAC,CAAA;QAC5B,CAAC;QAED,GAAG,CAAC,EAAE,CAAC,OAAO,EAAE,KAAK,CAAC,CAAA;QACtB,GAAG,CAAC,EAAE,CAAC,OAAO,EAAE,KAAK,CAAC,CAAA;IAC1B,CAAC,CAAC,CAAA;AACN,CAAC"}

lib/misc.d.ts

@@ -26,2 +26,3 @@ export declare function assertNotNull<T>(val: T | undefined | null, msg?: string): T;
 export declare function weakMemo<T extends object, R>(f: (obj: T) => R): (obj: T) => R;
+export declare function removeArrayItem<T>(arr: T[], item: T): void;
 //# sourceMappingURL=misc.d.ts.map

lib/misc.d.ts.map

@@ -1,1 +0,1 @@
-{"version":3,"file":"misc.d.ts","sourceRoot":"","sources":["../src/misc.ts"],"names":[],"mappings":"AAIA,wBAAgB,aAAa,CAAC,CAAC,EAAE,GAAG,EAAE,CAAC,GAAG,SAAS,GAAG,IAAI,EAAE,GAAG,CAAC,EAAE,MAAM,GAAG,CAAC,CAG3E;AAGD,wBAAgB,cAAc,CAAC,GAAG,CAAC,EAAE,OAAO,GAAG,KAAK,CAEnD;AAGD,wBAAgB,IAAI,CAAC,CAAC,EAAE,KAAK,EAAE,CAAC,EAAE,GAAG,CAAC,CAGrC;AAGD,wBAAgB,SAAS,CAAC,CAAC,EAAE,KAAK,EAAE,CAAC,EAAE,GAAG,CAAC,GAAG,SAAS,CAEtD;AAGD,wBAAgB,UAAU,CAAC,IAAI,EAAE,MAAM,OAAO,CAAC,IAAI,CAAC,EAAE,GAAG,CAAC,EAAE,CAAC,GAAG,EAAE,KAAK,KAAK,IAAI,GAAG,IAAI,CAgBtF;AAGD,qBAAa,aAAc,SAAQ,KAAK;aACR,KAAK,EAAE,OAAO;gBAAd,KAAK,EAAE,OAAO;CAG7C;AAGD,wBAAgB,WAAW,CAAC,GAAG,EAAE,OAAO,GAAG,KAAK,CAM/C;AAGD,wBAAgB,eAAe,CAAC,CAAC,SAAS,KAAK,EAAE,GAAG,EAAE,CAAC,EAAE,GAAG,EAAE,GAAG,GAAG,CAAC,CAQpE;AAGD,wBAAgB,gBAAgB,CAAC,GAAG,EAAE,GAAG,GAAG,CAAC,GAAG,EAAE,KAAK,KAAK,KAAK,CAIhE;AAGD,wBAAgB,iBAAiB,CAAC,MAAM,EAAE,CAAC,GAAG,IAAI,EAAE,GAAG,EAAE,KAAK,GAAG,GAAG,CAAC,KAAK,EAAE,GAAG,EAAE,IAAI,EAAE,MAAM,EAAE,CAAC,EAAE,kBAAkB,KAAK,kBAAkB,CAqB1I;AAGD,wBAAgB,kBAAkB,CAAC,MAAM,EAAE,CAAC,GAAG,IAAI,EAAE,GAAG,EAAE,KAAK,GAAG,GAAG,CAAC,KAAK,EAAE,GAAG,EAAE,IAAI,EAAE,MAAM,EAAE,CAAC,EAAE,kBAAkB,KAAK,kBAAkB,CAuB3I;AAGD,wBAAgB,IAAI,CAAC,EAAE,EAAE,MAAM,EAAE,WAAW,CAAC,EAAE,WAAW,GAAG,OAAO,CAAC,IAAI,CAAC,CAsBzE;AAGD,wBAAgB,OAAO,CAAC,CAAC,EAAE,CAAC,EAAE,QAAQ,EAAE,QAAQ,CAAC,CAAC,CAAC,EAAE,KAAK,EAAE,CAAC,CAAC,EAAE,CAAC,KAAK,CAAC,GAAG,GAAG,CAAC,CAAC,EAAE,CAAC,EAAE,CAAC,CAYpF;AAGD,wBAAiB,UAAU,CAAC,OAAO,EAAE,MAAM,EAAE,GAAG,EAAE,MAAM,EAAE,GAAG,CAAC,EAAE,MAAM,GAAG,QAAQ,CAAC,CAAC,GAAG,EAAE,MAAM,EAAE,GAAG,EAAE,MAAM,CAAC,CAAC,CAU5G;AAGD,wBAAiB,UAAU,CAAC,CAAC,EAAE,OAAO,EAAE,MAAM,EAAE,GAAG,EAAE,CAAC,EAAE,GAAG,QAAQ,CAAC,CAAC,EAAE,CAAC,CAQvE;AAGD,wBAAsB,iBAAiB,CAAC,CAAC,EAAE,CAAC,EAAE,OAAO,EAAE,MAAM,EAAE,KAAK,EAAE,CAAC,EAAE,EAAE,GAAG,EAAE,CAAC,KAAK,EAAE,CAAC,EAAE,KAAK,OAAO,CAAC,CAAC,EAAE,CAAC,GAAG,OAAO,CAAC,CAAC,EAAE,CAAC,CAa1H;AAGD,wBAAiB,WAAW,CAAC,CAAC,EAAE,CAAC,EAAE,KAAK,EAAE,CAAC,EAAE,EAAE,KAAK,EAAE,CAAC,CAAC,EAAE,CAAC,KAAK,CAAC,GAAG,QAAQ,CAAC;IAAC,KAAK,EAAE,CAAC,EAAE,CAAC;IAAC,KAAK,EAAE,CAAC,CAAA;CAAC,CAAC,CAkBnG;AAGD,wBAAgB,MAAM,CAAC,CAAC,EAAE,CAAC,EAAE,KAAK,EAAE,CAAC,EAAE,EAAE,GAAG,EAAE,CAAC,EAAE,OAAO,EAAE,CAAC,IAAI,EAAE,CAAC,EAAE,GAAG,EAAE,CAAC,KAAK,MAAM,GAAG,MAAM,CAgB7F;AAGD,wBAAgB,QAAQ,CAAC,CAAC,SAAS,MAAM,EAAE,CAAC,EAAE,CAAC,EAAE,CAAC,GAAG,EAAE,CAAC,KAAK,CAAC,GAAG,CAAC,GAAG,EAAE,CAAC,KAAK,CAAC,CAU7E"}
+{"version":3,"file":"misc.d.ts","sourceRoot":"","sources":["../src/misc.ts"],"names":[],"mappings":"AAIA,wBAAgB,aAAa,CAAC,CAAC,EAAE,GAAG,EAAE,CAAC,GAAG,SAAS,GAAG,IAAI,EAAE,GAAG,CAAC,EAAE,MAAM,GAAG,CAAC,CAG3E;AAGD,wBAAgB,cAAc,CAAC,GAAG,CAAC,EAAE,OAAO,GAAG,KAAK,CAEnD;AAGD,wBAAgB,IAAI,CAAC,CAAC,EAAE,KAAK,EAAE,CAAC,EAAE,GAAG,CAAC,CAGrC;AAGD,wBAAgB,SAAS,CAAC,CAAC,EAAE,KAAK,EAAE,CAAC,EAAE,GAAG,CAAC,GAAG,SAAS,CAEtD;AAGD,wBAAgB,UAAU,CAAC,IAAI,EAAE,MAAM,OAAO,CAAC,IAAI,CAAC,EAAE,GAAG,CAAC,EAAE,CAAC,GAAG,EAAE,KAAK,KAAK,IAAI,GAAG,IAAI,CAgBtF;AAGD,qBAAa,aAAc,SAAQ,KAAK;aACR,KAAK,EAAE,OAAO;gBAAd,KAAK,EAAE,OAAO;CAG7C;AAGD,wBAAgB,WAAW,CAAC,GAAG,EAAE,OAAO,GAAG,KAAK,CAM/C;AAGD,wBAAgB,eAAe,CAAC,CAAC,SAAS,KAAK,EAAE,GAAG,EAAE,CAAC,EAAE,GAAG,EAAE,GAAG,GAAG,CAAC,CAQpE;AAGD,wBAAgB,gBAAgB,CAAC,GAAG,EAAE,GAAG,GAAG,CAAC,GAAG,EAAE,KAAK,KAAK,KAAK,CAIhE;AAGD,wBAAgB,iBAAiB,CAAC,MAAM,EAAE,CAAC,GAAG,IAAI,EAAE,GAAG,EAAE,KAAK,GAAG,GAAG,CAAC,KAAK,EAAE,GAAG,EAAE,IAAI,EAAE,MAAM,EAAE,CAAC,EAAE,kBAAkB,KAAK,kBAAkB,CAqB1I;AAGD,wBAAgB,kBAAkB,CAAC,MAAM,EAAE,CAAC,GAAG,IAAI,EAAE,GAAG,EAAE,KAAK,GAAG,GAAG,CAAC,KAAK,EAAE,GAAG,EAAE,IAAI,EAAE,MAAM,EAAE,CAAC,EAAE,kBAAkB,KAAK,kBAAkB,CAuB3I;AAGD,wBAAgB,IAAI,CAAC,EAAE,EAAE,MAAM,EAAE,WAAW,CAAC,EAAE,WAAW,GAAG,OAAO,CAAC,IAAI,CAAC,CAsBzE;AAGD,wBAAgB,OAAO,CAAC,CAAC,EAAE,CAAC,EAAE,QAAQ,EAAE,QAAQ,CAAC,CAAC,CAAC,EAAE,KAAK,EAAE,CAAC,CAAC,EAAE,CAAC,KAAK,CAAC,GAAG,GAAG,CAAC,CAAC,EAAE,CAAC,EAAE,CAAC,CAYpF;AAGD,wBAAiB,UAAU,CAAC,OAAO,EAAE,MAAM,EAAE,GAAG,EAAE,MAAM,EAAE,GAAG,CAAC,EAAE,MAAM,GAAG,QAAQ,CAAC,CAAC,GAAG,EAAE,MAAM,EAAE,GAAG,EAAE,MAAM,CAAC,CAAC,CAU5G;AAGD,wBAAiB,UAAU,CAAC,CAAC,EAAE,OAAO,EAAE,MAAM,EAAE,GAAG,EAAE,CAAC,EAAE,GAAG,QAAQ,CAAC,CAAC,EAAE,CAAC,CAQvE;AAGD,wBAAsB,iBAAiB,CAAC,CAAC,EAAE,CAAC,EAAE,OAAO,EAAE,MAAM,EAAE,KAAK,EAAE,CAAC,EAAE,EAAE,GAAG,EAAE,CAAC,KAAK,EAAE,CAAC,EAAE,KAAK,OAAO,CAAC,CAAC,EAAE,CAAC,GAAG,OAAO,CAAC,CAAC,EAAE,CAAC,CAa1H;AAGD,wBAAiB,WAAW,CAAC,CAAC,EAAE,CAAC,EAAE,KAAK,EAAE,CAAC,EAAE,EAAE,KAAK,EAAE,CAAC,CAAC,EAAE,CAAC,KAAK,CAAC,GAAG,QAAQ,CAAC;IAAC,KAAK,EAAE,CAAC,EAAE,CAAC;IAAC,KAAK,EAAE,CAAC,CAAA;CAAC,CAAC,CAkBnG;AAGD,wBAAgB,MAAM,CAAC,CAAC,EAAE,CAAC,EAAE,KAAK,EAAE,CAAC,EAAE,EAAE,GAAG,EAAE,CAAC,EAAE,OAAO,EAAE,CAAC,IAAI,EAAE,CAAC,EAAE,GAAG,EAAE,CAAC,KAAK,MAAM,GAAG,MAAM,CAgB7F;AAGD,wBAAgB,QAAQ,CAAC,CAAC,SAAS,MAAM,EAAE,CAAC,EAAE,CAAC,EAAE,CAAC,GAAG,EAAE,CAAC,KAAK,CAAC,GAAG,CAAC,GAAG,EAAE,CAAC,KAAK,CAAC,CAU7E;AAGD,wBAAgB,eAAe,CAAC,CAAC,EAAE,GAAG,EAAE,CAAC,EAAE,EAAE,IAAI,EAAE,CAAC,GAAG,IAAI,CAI1D"}

lib/misc.js

@@ -29,3 +29,22 @@ "use strict";
 Object.defineProperty(exports, "__esModule", { value: true });
-exports.weakMemo = exports.bisect = exports.partitionBy = exports.splitParallelWork = exports.splitArray = exports.splitSlice = exports.groupBy = exports.wait = exports.annotateAsyncError = exports.annotateSyncError = exports.withErrorContext = exports.addErrorContext = exports.ensureError = exports.NonErrorThrow = exports.runProgram = exports.maybeLast = exports.last = exports.unexpectedCase = exports.assertNotNull = void 0;
+exports.NonErrorThrow = void 0;
+exports.assertNotNull = assertNotNull;
+exports.unexpectedCase = unexpectedCase;
+exports.last = last;
+exports.maybeLast = maybeLast;
+exports.runProgram = runProgram;
+exports.ensureError = ensureError;
+exports.addErrorContext = addErrorContext;
+exports.withErrorContext = withErrorContext;
+exports.annotateSyncError = annotateSyncError;
+exports.annotateAsyncError = annotateAsyncError;
+exports.wait = wait;
+exports.groupBy = groupBy;
+exports.splitSlice = splitSlice;
+exports.splitArray = splitArray;
+exports.splitParallelWork = splitParallelWork;
+exports.partitionBy = partitionBy;
+exports.bisect = bisect;
+exports.weakMemo = weakMemo;
+exports.removeArrayItem = removeArrayItem;
 const assert_1 = __importDefault(require("assert"));
@@ -37,7 +56,5 @@ const process = __importStar(require("process"));
 }
-exports.assertNotNull = assertNotNull;
 function unexpectedCase(val) {
     return new Error(val ? `Unexpected case: ${val}` : `Unexpected case`);
 }
-exports.unexpectedCase = unexpectedCase;
 function last(array) {
@@ -47,7 +64,5 @@ (0, assert_1.default)(array.length > 0);
 }
-exports.last = last;
 function maybeLast(array) {
     return array.length > 0 ? array[array.length - 1] : undefined;
 }
-exports.maybeLast = maybeLast;
 function runProgram(main, log) {
@@ -70,3 +85,2 @@ function onerror(err) {
 }
-exports.runProgram = runProgram;
 class NonErrorThrow extends Error {
@@ -87,3 +101,2 @@ constructor(value) {
 }
-exports.ensureError = ensureError;
 function addErrorContext(err, ctx) {
@@ -98,3 +111,2 @@ let e = err;
 }
-exports.addErrorContext = addErrorContext;
 function withErrorContext(ctx) {
@@ -105,3 +117,2 @@ return function (err) {
 }
-exports.withErrorContext = withErrorContext;
 function annotateSyncError(getCtx) {
@@ -124,3 +135,2 @@ return function decorate(proto, prop, d) {
 }
-exports.annotateSyncError = annotateSyncError;
 function annotateAsyncError(getCtx) {
@@ -145,3 +155,2 @@ return function decorate(proto, prop, d) {
 }
-exports.annotateAsyncError = annotateAsyncError;
 function wait(ms, abortSignal) {
@@ -169,3 +178,2 @@ if (abortSignal) {
 }
-exports.wait = wait;
 function groupBy(elements, group) {
@@ -185,3 +193,2 @@ let grouping = new Map();
 }
-exports.groupBy = groupBy;
 function* splitSlice(maxSize, beg, end) {
@@ -198,3 +205,2 @@ (0, assert_1.default)(maxSize >= 1);
 }
-exports.splitSlice = splitSlice;
 function* splitArray(maxSize, arr) {
@@ -210,3 +216,2 @@ if (arr.length <= maxSize) {
 }
-exports.splitArray = splitArray;
 async function splitParallelWork(maxSize, tasks, run) {
@@ -225,3 +230,2 @@ if (tasks.length <= maxSize)
 }
-exports.splitParallelWork = splitParallelWork;
 function* partitionBy(items, value) {
@@ -248,3 +252,2 @@ if (items.length == 0)
 }
-exports.partitionBy = partitionBy;
 function bisect(items, key, compare) {
@@ -269,3 +272,2 @@ let beg = 0;
 }
-exports.bisect = bisect;
 function weakMemo(f) {
@@ -282,3 +284,8 @@ let cache = new WeakMap();
 }
-exports.weakMemo = weakMemo;
+function removeArrayItem(arr, item) {
+    let index = arr.indexOf(item);
+    if (index < 0)
+        return;
+    arr.splice(index, 1);
+}
 //# sourceMappingURL=misc.js.map

lib/misc.js.map

@@ -1,1 +0,1 @@
-{"version":3,"file":"misc.js","sourceRoot":"","sources":["../src/misc.ts"],"names":[],"mappings":";;;;;;;;;;;;;;;;;;;;;;;;;;;;;AAAA,oDAA2B;AAC3B,iDAAkC;AAGlC,SAAgB,aAAa,CAAI,GAAyB,EAAE,GAAY;IACpE,IAAA,gBAAM,EAAC,GAAG,IAAI,IAAI,EAAE,GAAG,CAAC,CAAA;IACxB,OAAO,GAAG,CAAA;AACd,CAAC;AAHD,sCAGC;AAGD,SAAgB,cAAc,CAAC,GAAa;IACxC,OAAO,IAAI,KAAK,CAAC,GAAG,CAAC,CAAC,CAAC,oBAAoB,GAAG,EAAE,CAAC,CAAC,CAAC,iBAAiB,CAAC,CAAA;AACzE,CAAC;AAFD,wCAEC;AAGD,SAAgB,IAAI,CAAI,KAAU;IAC9B,IAAA,gBAAM,EAAC,KAAK,CAAC,MAAM,GAAG,CAAC,CAAC,CAAA;IACxB,OAAO,KAAK,CAAC,KAAK,CAAC,MAAM,GAAG,CAAC,CAAC,CAAA;AAClC,CAAC;AAHD,oBAGC;AAGD,SAAgB,SAAS,CAAI,KAAU;IACnC,OAAO,KAAK,CAAC,MAAM,GAAG,CAAC,CAAC,CAAC,CAAC,KAAK,CAAC,KAAK,CAAC,MAAM,GAAG,CAAC,CAAC,CAAC,CAAC,CAAC,SAAS,CAAA;AACjE,CAAC;AAFD,8BAEC;AAGD,SAAgB,UAAU,CAAC,IAAyB,EAAE,GAA0B;IAE5E,SAAS,OAAO,CAAC,GAAY;QACzB,IAAI,GAAG,EAAE,CAAC;YACN,GAAG,CAAC,WAAW,CAAC,GAAG,CAAC,CAAC,CAAA;QACzB,CAAC;aAAM,CAAC;YACJ,OAAO,CAAC,KAAK,CAAC,GAAG,CAAC,CAAA;QACtB,CAAC;QACD,OAAO,CAAC,IAAI,CAAC,CAAC,CAAC,CAAA;IACnB,CAAC;IAED,IAAI,CAAC;QACD,IAAI,EAAE,CAAC,IAAI,CAAC,GAAG,EAAE,CAAC,OAAO,CAAC,IAAI,CAAC,CAAC,CAAC,EAAE,OAAO,CAAC,CAAA;IAC/C,CAAC;IAAC,OAAM,CAAU,EAAE,CAAC;QACjB,OAAO,CAAC,CAAC,CAAC,CAAA;IACd,CAAC;AACL,CAAC;AAhBD,gCAgBC;AAGD,MAAa,aAAc,SAAQ,KAAK;IACpC,YAA4B,KAAc;QACtC,KAAK,CAAC,6BAA6B,CAAC,CAAA;QADZ,UAAK,GAAL,KAAK,CAAS;IAE1C,CAAC;CACJ;AAJD,sCAIC;AAGD,SAAgB,WAAW,CAAC,GAAY;IACpC,IAAI,GAAG,YAAY,KAAK,EAAE,CAAC;QACvB,OAAO,GAAG,CAAA;IACd,CAAC;SAAM,CAAC;QACJ,OAAO,IAAI,aAAa,CAAC,GAAG,CAAC,CAAA;IACjC,CAAC;AACL,CAAC;AAND,kCAMC;AAGD,SAAgB,eAAe,CAAkB,GAAM,EAAE,GAAQ;IAC7D,IAAI,CAAC,GAAG,GAAU,CAAA;IAClB,KAAK,IAAI,GAAG,IAAI,GAAG,EAAE,CAAC;QAClB,IAAI,CAAC,CAAC,GAAG,CAAC,IAAI,IAAI,EAAE,CAAC;YACjB,CAAC,CAAC,GAAG,CAAC,GAAG,GAAG,CAAC,GAAG,CAAC,CAAA;QACrB,CAAC;IACL,CAAC;IACD,OAAO,GAAG,CAAA;AACd,CAAC;AARD,0CAQC;AAGD,SAAgB,gBAAgB,CAAC,GAAQ;IACrC,OAAO,UAAS,GAAU;QACtB,MAAM,eAAe,CAAC,GAAG,EAAE,GAAG,CAAC,CAAA;IACnC,CAAC,CAAA;AACL,CAAC;AAJD,4CAIC;AAGD,SAAgB,iBAAiB,CAAC,MAA+B;IAC7D,OAAO,SAAS,QAAQ,CAAC,KAAU,EAAE,IAAY,EAAE,CAAqB;QACpE,IAAI,EAAC,KAAK,EAAE,EAAE,EAAE,GAAG,OAAO,EAAC,GAAG,CAAC,CAAA;QAE/B,SAAS,QAAQ,CAAC,GAAQ,EAAE,IAAW;YACnC,OAAO,eAAe,CAClB,WAAW,CAAC,GAAG,CAAC,EAChB,MAAM,CAAC,GAAG,IAAI,CAAC,CAClB,CAAA;QACL,CAAC;QAED,IAAI,KAAK,GAAG,UAAoB,GAAG,IAAW;YAC1C,IAAI,CAAC;gBACD,OAAO,EAAE,CAAC,KAAK,CAAC,IAAI,EAAE,IAAI,CAAC,CAAA;YAC/B,CAAC;YAAC,OAAM,GAAQ,EAAE,CAAC;gBACf,MAAM,QAAQ,CAAC,GAAG,EAAE,IAAI,CAAC,CAAA;YAC7B,CAAC;QACL,CAAQ,CAAA;QAER,OAAO,EAAC,KAAK,EAAE,GAAG,OAAO,EAAC,CAAA;IAC9B,CAAC,CAAA;AACL,CAAC;AArBD,8CAqBC;AAGD,SAAgB,kBAAkB,CAAC,MAA+B;IAC9D,OAAO,SAAS,QAAQ,CAAC,KAAU,EAAE,IAAY,EAAE,CAAqB;QACpE,IAAI,EAAC,KAAK,EAAE,EAAE,EAAE,GAAG,OAAO,EAAC,GAAG,CAAC,CAAA;QAE/B,SAAS,QAAQ,CAAC,GAAQ,EAAE,IAAW;YACnC,OAAO,eAAe,CAClB,WAAW,CAAC,GAAG,CAAC,EAChB,MAAM,CAAC,GAAG,IAAI,CAAC,CAClB,CAAA;QACL,CAAC;QAED,IAAI,KAAK,GAAG,UAAoB,GAAG,IAAW;YAC1C,IAAI,CAAC;gBACD,OAAO,EAAE,CAAC,KAAK,CAAC,IAAI,EAAE,IAAI,CAAC,CAAC,KAAK,CAAC,CAAC,GAAQ,EAAE,EAAE;oBAC3C,MAAM,QAAQ,CAAC,GAAG,EAAE,IAAI,CAAC,CAAA;gBAC7B,CAAC,CAAC,CAAA;YACN,CAAC;YAAC,OAAM,GAAQ,EAAE,CAAC;gBACf,MAAM,QAAQ,CAAC,GAAG,EAAE,IAAI,CAAC,CAAA;YAC7B,CAAC;QACL,CAAQ,CAAA;QAER,OAAO,EAAC,KAAK,EAAE,GAAG,OAAO,EAAC,CAAA;IAC9B,CAAC,CAAA;AACL,CAAC;AAvBD,gDAuBC;AAGD,SAAgB,IAAI,CAAC,EAAU,EAAE,WAAyB;IACtD,IAAI,WAAW,EAAE,CAAC;QACd,OAAO,IAAI,OAAO,CAAC,CAAC,OAAO,EAAE,MAAM,EAAE,EAAE;YACnC,IAAI,WAAW,CAAC,OAAO;gBAAE,OAAO,MAAM,CAAC,IAAI,KAAK,CAAC,SAAS,CAAC,CAAC,CAAA;YAE5D,WAAW,CAAC,gBAAgB,CAAC,OAAO,EAAE,KAAK,EAAE,EAAC,IAAI,EAAE,IAAI,EAAC,CAAC,CAAA;YAE1D,IAAI,KAAK,GAAG,UAAU,CAAC,GAAG,EAAE;gBACxB,WAAW,CAAC,mBAAmB,CAAC,OAAO,EAAE,KAAK,CAAC,CAAA;gBAC/C,OAAO,EAAE,CAAA;YACb,CAAC,EAAE,EAAE,CAAC,CAAA;YAEN,SAAS,KAAK;gBACV,YAAY,CAAC,KAAK,CAAC,CAAA;gBACnB,MAAM,CAAC,IAAI,KAAK,CAAC,SAAS,CAAC,CAAC,CAAA;YAChC,CAAC;QACL,CAAC,CAAC,CAAA;IACN,CAAC;SAAM,CAAC;QACJ,OAAO,IAAI,OAAO,CAAC,OAAO,CAAC,EAAE;YACzB,UAAU,CAAC,OAAO,EAAE,EAAE,CAAC,CAAA;QAC3B,CAAC,CAAC,CAAA;IACN,CAAC;AACL,CAAC;AAtBD,oBAsBC;AAGD,SAAgB,OAAO,CAAO,QAAqB,EAAE,KAAkB;IACnE,IAAI,QAAQ,GAAG,IAAI,GAAG,EAAU,CAAA;IAChC,KAAK,IAAI,OAAO,IAAI,QAAQ,EAAE,CAAC;QAC3B,IAAI,GAAG,GAAG,KAAK,CAAC,OAAO,CAAC,CAAA;QACxB,IAAI,CAAC,GAAG,QAAQ,CAAC,GAAG,CAAC,GAAG,CAAC,CAAA;QACzB,IAAI,CAAC,IAAI,IAAI,EAAE,CAAC;YACZ,QAAQ,CAAC,GAAG,CAAC,GAAG,EAAE,CAAC,OAAO,CAAC,CAAC,CAAA;QAChC,CAAC;aAAM,CAAC;YACJ,CAAC,CAAC,IAAI,CAAC,OAAO,CAAC,CAAA;QACnB,CAAC;IACL,CAAC;IACD,OAAO,QAAQ,CAAA;AACnB,CAAC;AAZD,0BAYC;AAGD,QAAe,CAAC,CAAC,UAAU,CAAC,OAAe,EAAE,GAAW,EAAE,GAAY;IAClE,IAAA,gBAAM,EAAC,OAAO,IAAI,CAAC,CAAC,CAAA;IACpB,GAAG,GAAG,GAAG,IAAI,MAAM,CAAC,gBAAgB,CAAA;IACpC,OAAO,GAAG,GAAG,GAAG,EAAE,CAAC;QACf,IAAI,IAAI,GAAG,GAAG,GAAG,GAAG,CAAA;QACpB,IAAI,MAAM,GAAG,IAAI,CAAC,IAAI,CAAC,IAAI,GAAG,OAAO,CAAC,CAAA;QACtC,IAAI,IAAI,GAAG,IAAI,CAAC,KAAK,CAAC,IAAI,GAAG,MAAM,CAAC,CAAA;QACpC,MAAM,CAAC,GAAG,EAAE,GAAG,GAAG,IAAI,CAAC,CAAA;QACvB,GAAG,IAAI,IAAI,CAAA;IACf,CAAC;AACL,CAAC;AAVD,gCAUC;AAGD,QAAe,CAAC,CAAC,UAAU,CAAI,OAAe,EAAE,GAAQ;IACpD,IAAI,GAAG,CAAC,MAAM,IAAI,OAAO,EAAE,CAAC;QACxB,MAAM,GAAG,CAAA;IACb,CAAC;SAAM,CAAC;QACJ,KAAK,IAAI,CAAC,GAAG,EAAE,GAAG,CAAC,IAAI,UAAU,CAAC,OAAO,EAAE,CAAC,EAAE,GAAG,CAAC,MAAM,CAAC,EAAE,CAAC;YACxD,MAAM,GAAG,CAAC,KAAK,CAAC,GAAG,EAAE,GAAG,CAAC,CAAA;QAC7B,CAAC;IACL,CAAC;AACL,CAAC;AARD,gCAQC;AAGM,KAAK,UAAU,iBAAiB,CAAO,OAAe,EAAE,KAAU,EAAE,GAAiC;IACxG,IAAI,KAAK,CAAC,MAAM,IAAI,OAAO;QAAE,OAAO,GAAG,CAAC,KAAK,CAAC,CAAA;IAE9C,IAAI,QAAQ,GAAmB,EAAE,CAAA;IACjC,KAAK,IAAI,KAAK,IAAI,UAAU,CAAC,OAAO,EAAE,KAAK,CAAC,EAAE,CAAC;QAC3C,QAAQ,CAAC,IAAI,CAAC,GAAG,CAAC,KAAK,CAAC,CAAC,CAAA;IAC7B,CAAC;IAED,IAAI,MAAM,GAAQ,EAAE,CAAA;IACpB,KAAK,IAAI,KAAK,IAAI,MAAM,OAAO,CAAC,GAAG,CAAC,QAAQ,CAAC,EAAE,CAAC;QAC5C,MAAM,CAAC,IAAI,CAAC,GAAG,KAAK,CAAC,CAAA;IACzB,CAAC;IACD,OAAO,MAAM,CAAA;AACjB,CAAC;AAbD,8CAaC;AAGD,QAAe,CAAC,CAAC,WAAW,CAAO,KAAU,EAAE,KAAkB;IAC7D,IAAI,KAAK,CAAC,MAAM,IAAI,CAAC;QAAE,OAAM;IAC7B,IAAI,IAAI,GAAQ,CAAC,KAAK,CAAC,CAAC,CAAC,CAAC,CAAA;IAC1B,IAAI,SAAS,GAAG,KAAK,CAAC,KAAK,CAAC,CAAC,CAAC,CAAC,CAAA;IAC/B,KAAK,IAAI,CAAC,GAAG,CAAC,EAAE,CAAC,GAAG,KAAK,CAAC,MAAM,EAAE,CAAC,EAAE,EAAE,CAAC;QACpC,IAAI,IAAI,GAAG,KAAK,CAAC,CAAC,CAAC,CAAA;QACnB,IAAI,SAAS,GAAG,KAAK,CAAC,IAAI,CAAC,CAAA;QAC3B,IAAI,SAAS,KAAK,SAAS,EAAE,CAAC;YAC1B,IAAI,CAAC,IAAI,CAAC,IAAI,CAAC,CAAA;QACnB,CAAC;aAAM,CAAC;YACJ,MAAM,EAAC,KAAK,EAAE,IAAI,EAAE,KAAK,EAAE,SAAS,EAAC,CAAA;YACrC,IAAI,GAAG,CAAC,IAAI,CAAC,CAAA;YACb,SAAS,GAAG,SAAS,CAAA;QACzB,CAAC;IACL,CAAC;IACD,IAAI,IAAI,CAAC,MAAM,GAAG,CAAC,EAAE,CAAC;QAClB,MAAM,EAAC,KAAK,EAAE,IAAI,EAAE,KAAK,EAAE,SAAS,EAAC,CAAA;IACzC,CAAC;AACL,CAAC;AAlBD,kCAkBC;AAGD,SAAgB,MAAM,CAAO,KAAU,EAAE,GAAM,EAAE,OAAoC;IACjF,IAAI,GAAG,GAAG,CAAC,CAAA;IACX,IAAI,GAAG,GAAG,KAAK,CAAC,MAAM,CAAA;IACtB,OAAO,GAAG,GAAG,GAAG,EAAE,CAAC;QACf,IAAI,IAAI,GAAG,GAAG,GAAG,GAAG,CAAA;QACpB,IAAI,GAAG,GAAG,GAAG,GAAG,CAAC,IAAI,GAAG,CAAC,IAAI,GAAG,CAAC,CAAC,CAAC,GAAG,CAAC,CAAA;QACvC,IAAI,EAAE,GAAG,KAAK,CAAC,GAAG,CAAC,CAAA;QACnB,IAAI,KAAK,GAAG,OAAO,CAAC,EAAE,EAAE,GAAG,CAAC,CAAA;QAC5B,IAAI,KAAK,IAAI,CAAC;YAAE,OAAO,GAAG,CAAA;QAC1B,IAAI,KAAK,GAAG,CAAC,EAAE,CAAC;YACZ,GAAG,GAAG,GAAG,CAAA;QACb,CAAC;aAAM,CAAC;YACJ,GAAG,GAAG,GAAG,GAAG,CAAC,CAAA;QACjB,CAAC;IACL,CAAC;IACD,OAAO,GAAG,CAAA;AACd,CAAC;AAhBD,wBAgBC;AAGD,SAAgB,QAAQ,CAAsB,CAAgB;IAC1D,IAAI,KAAK,GAAG,IAAI,OAAO,EAAQ,CAAA;IAC/B,OAAO,UAAS,GAAM;QAClB,IAAI,GAAG,GAAG,KAAK,CAAC,GAAG,CAAC,GAAG,CAAC,CAAA;QACxB,IAAI,GAAG,KAAK,SAAS,EAAE,CAAC;YACpB,GAAG,GAAG,CAAC,CAAC,GAAG,CAAC,CAAA;YACZ,KAAK,CAAC,GAAG,CAAC,GAAG,EAAE,GAAG,CAAC,CAAA;QACvB,CAAC;QACD,OAAO,GAAG,CAAA;IACd,CAAC,CAAA;AACL,CAAC;AAVD,4BAUC"}
+{"version":3,"file":"misc.js","sourceRoot":"","sources":["../src/misc.ts"],"names":[],"mappings":";;;;;;;;;;;;;;;;;;;;;;;;;;;;;AAIA,sCAGC;AAGD,wCAEC;AAGD,oBAGC;AAGD,8BAEC;AAGD,gCAgBC;AAUD,kCAMC;AAGD,0CAQC;AAGD,4CAIC;AAGD,8CAqBC;AAGD,gDAuBC;AAGD,oBAsBC;AAGD,0BAYC;AAGD,gCAUC;AAGD,gCAQC;AAGD,8CAaC;AAGD,kCAkBC;AAGD,wBAgBC;AAGD,4BAUC;AAGD,0CAIC;AA1QD,oDAA2B;AAC3B,iDAAkC;AAGlC,SAAgB,aAAa,CAAI,GAAyB,EAAE,GAAY;IACpE,IAAA,gBAAM,EAAC,GAAG,IAAI,IAAI,EAAE,GAAG,CAAC,CAAA;IACxB,OAAO,GAAG,CAAA;AACd,CAAC;AAGD,SAAgB,cAAc,CAAC,GAAa;IACxC,OAAO,IAAI,KAAK,CAAC,GAAG,CAAC,CAAC,CAAC,oBAAoB,GAAG,EAAE,CAAC,CAAC,CAAC,iBAAiB,CAAC,CAAA;AACzE,CAAC;AAGD,SAAgB,IAAI,CAAI,KAAU;IAC9B,IAAA,gBAAM,EAAC,KAAK,CAAC,MAAM,GAAG,CAAC,CAAC,CAAA;IACxB,OAAO,KAAK,CAAC,KAAK,CAAC,MAAM,GAAG,CAAC,CAAC,CAAA;AAClC,CAAC;AAGD,SAAgB,SAAS,CAAI,KAAU;IACnC,OAAO,KAAK,CAAC,MAAM,GAAG,CAAC,CAAC,CAAC,CAAC,KAAK,CAAC,KAAK,CAAC,MAAM,GAAG,CAAC,CAAC,CAAC,CAAC,CAAC,SAAS,CAAA;AACjE,CAAC;AAGD,SAAgB,UAAU,CAAC,IAAyB,EAAE,GAA0B;IAE5E,SAAS,OAAO,CAAC,GAAY;QACzB,IAAI,GAAG,EAAE,CAAC;YACN,GAAG,CAAC,WAAW,CAAC,GAAG,CAAC,CAAC,CAAA;QACzB,CAAC;aAAM,CAAC;YACJ,OAAO,CAAC,KAAK,CAAC,GAAG,CAAC,CAAA;QACtB,CAAC;QACD,OAAO,CAAC,IAAI,CAAC,CAAC,CAAC,CAAA;IACnB,CAAC;IAED,IAAI,CAAC;QACD,IAAI,EAAE,CAAC,IAAI,CAAC,GAAG,EAAE,CAAC,OAAO,CAAC,IAAI,CAAC,CAAC,CAAC,EAAE,OAAO,CAAC,CAAA;IAC/C,CAAC;IAAC,OAAM,CAAU,EAAE,CAAC;QACjB,OAAO,CAAC,CAAC,CAAC,CAAA;IACd,CAAC;AACL,CAAC;AAGD,MAAa,aAAc,SAAQ,KAAK;IACpC,YAA4B,KAAc;QACtC,KAAK,CAAC,6BAA6B,CAAC,CAAA;QADZ,UAAK,GAAL,KAAK,CAAS;IAE1C,CAAC;CACJ;AAJD,sCAIC;AAGD,SAAgB,WAAW,CAAC,GAAY;IACpC,IAAI,GAAG,YAAY,KAAK,EAAE,CAAC;QACvB,OAAO,GAAG,CAAA;IACd,CAAC;SAAM,CAAC;QACJ,OAAO,IAAI,aAAa,CAAC,GAAG,CAAC,CAAA;IACjC,CAAC;AACL,CAAC;AAGD,SAAgB,eAAe,CAAkB,GAAM,EAAE,GAAQ;IAC7D,IAAI,CAAC,GAAG,GAAU,CAAA;IAClB,KAAK,IAAI,GAAG,IAAI,GAAG,EAAE,CAAC;QAClB,IAAI,CAAC,CAAC,GAAG,CAAC,IAAI,IAAI,EAAE,CAAC;YACjB,CAAC,CAAC,GAAG,CAAC,GAAG,GAAG,CAAC,GAAG,CAAC,CAAA;QACrB,CAAC;IACL,CAAC;IACD,OAAO,GAAG,CAAA;AACd,CAAC;AAGD,SAAgB,gBAAgB,CAAC,GAAQ;IACrC,OAAO,UAAS,GAAU;QACtB,MAAM,eAAe,CAAC,GAAG,EAAE,GAAG,CAAC,CAAA;IACnC,CAAC,CAAA;AACL,CAAC;AAGD,SAAgB,iBAAiB,CAAC,MAA+B;IAC7D,OAAO,SAAS,QAAQ,CAAC,KAAU,EAAE,IAAY,EAAE,CAAqB;QACpE,IAAI,EAAC,KAAK,EAAE,EAAE,EAAE,GAAG,OAAO,EAAC,GAAG,CAAC,CAAA;QAE/B,SAAS,QAAQ,CAAC,GAAQ,EAAE,IAAW;YACnC,OAAO,eAAe,CAClB,WAAW,CAAC,GAAG,CAAC,EAChB,MAAM,CAAC,GAAG,IAAI,CAAC,CAClB,CAAA;QACL,CAAC;QAED,IAAI,KAAK,GAAG,UAAoB,GAAG,IAAW;YAC1C,IAAI,CAAC;gBACD,OAAO,EAAE,CAAC,KAAK,CAAC,IAAI,EAAE,IAAI,CAAC,CAAA;YAC/B,CAAC;YAAC,OAAM,GAAQ,EAAE,CAAC;gBACf,MAAM,QAAQ,CAAC,GAAG,EAAE,IAAI,CAAC,CAAA;YAC7B,CAAC;QACL,CAAQ,CAAA;QAER,OAAO,EAAC,KAAK,EAAE,GAAG,OAAO,EAAC,CAAA;IAC9B,CAAC,CAAA;AACL,CAAC;AAGD,SAAgB,kBAAkB,CAAC,MAA+B;IAC9D,OAAO,SAAS,QAAQ,CAAC,KAAU,EAAE,IAAY,EAAE,CAAqB;QACpE,IAAI,EAAC,KAAK,EAAE,EAAE,EAAE,GAAG,OAAO,EAAC,GAAG,CAAC,CAAA;QAE/B,SAAS,QAAQ,CAAC,GAAQ,EAAE,IAAW;YACnC,OAAO,eAAe,CAClB,WAAW,CAAC,GAAG,CAAC,EAChB,MAAM,CAAC,GAAG,IAAI,CAAC,CAClB,CAAA;QACL,CAAC;QAED,IAAI,KAAK,GAAG,UAAoB,GAAG,IAAW;YAC1C,IAAI,CAAC;gBACD,OAAO,EAAE,CAAC,KAAK,CAAC,IAAI,EAAE,IAAI,CAAC,CAAC,KAAK,CAAC,CAAC,GAAQ,EAAE,EAAE;oBAC3C,MAAM,QAAQ,CAAC,GAAG,EAAE,IAAI,CAAC,CAAA;gBAC7B,CAAC,CAAC,CAAA;YACN,CAAC;YAAC,OAAM,GAAQ,EAAE,CAAC;gBACf,MAAM,QAAQ,CAAC,GAAG,EAAE,IAAI,CAAC,CAAA;YAC7B,CAAC;QACL,CAAQ,CAAA;QAER,OAAO,EAAC,KAAK,EAAE,GAAG,OAAO,EAAC,CAAA;IAC9B,CAAC,CAAA;AACL,CAAC;AAGD,SAAgB,IAAI,CAAC,EAAU,EAAE,WAAyB;IACtD,IAAI,WAAW,EAAE,CAAC;QACd,OAAO,IAAI,OAAO,CAAC,CAAC,OAAO,EAAE,MAAM,EAAE,EAAE;YACnC,IAAI,WAAW,CAAC,OAAO;gBAAE,OAAO,MAAM,CAAC,IAAI,KAAK,CAAC,SAAS,CAAC,CAAC,CAAA;YAE5D,WAAW,CAAC,gBAAgB,CAAC,OAAO,EAAE,KAAK,EAAE,EAAC,IAAI,EAAE,IAAI,EAAC,CAAC,CAAA;YAE1D,IAAI,KAAK,GAAG,UAAU,CAAC,GAAG,EAAE;gBACxB,WAAW,CAAC,mBAAmB,CAAC,OAAO,EAAE,KAAK,CAAC,CAAA;gBAC/C,OAAO,EAAE,CAAA;YACb,CAAC,EAAE,EAAE,CAAC,CAAA;YAEN,SAAS,KAAK;gBACV,YAAY,CAAC,KAAK,CAAC,CAAA;gBACnB,MAAM,CAAC,IAAI,KAAK,CAAC,SAAS,CAAC,CAAC,CAAA;YAChC,CAAC;QACL,CAAC,CAAC,CAAA;IACN,CAAC;SAAM,CAAC;QACJ,OAAO,IAAI,OAAO,CAAC,OAAO,CAAC,EAAE;YACzB,UAAU,CAAC,OAAO,EAAE,EAAE,CAAC,CAAA;QAC3B,CAAC,CAAC,CAAA;IACN,CAAC;AACL,CAAC;AAGD,SAAgB,OAAO,CAAO,QAAqB,EAAE,KAAkB;IACnE,IAAI,QAAQ,GAAG,IAAI,GAAG,EAAU,CAAA;IAChC,KAAK,IAAI,OAAO,IAAI,QAAQ,EAAE,CAAC;QAC3B,IAAI,GAAG,GAAG,KAAK,CAAC,OAAO,CAAC,CAAA;QACxB,IAAI,CAAC,GAAG,QAAQ,CAAC,GAAG,CAAC,GAAG,CAAC,CAAA;QACzB,IAAI,CAAC,IAAI,IAAI,EAAE,CAAC;YACZ,QAAQ,CAAC,GAAG,CAAC,GAAG,EAAE,CAAC,OAAO,CAAC,CAAC,CAAA;QAChC,CAAC;aAAM,CAAC;YACJ,CAAC,CAAC,IAAI,CAAC,OAAO,CAAC,CAAA;QACnB,CAAC;IACL,CAAC;IACD,OAAO,QAAQ,CAAA;AACnB,CAAC;AAGD,QAAe,CAAC,CAAC,UAAU,CAAC,OAAe,EAAE,GAAW,EAAE,GAAY;IAClE,IAAA,gBAAM,EAAC,OAAO,IAAI,CAAC,CAAC,CAAA;IACpB,GAAG,GAAG,GAAG,IAAI,MAAM,CAAC,gBAAgB,CAAA;IACpC,OAAO,GAAG,GAAG,GAAG,EAAE,CAAC;QACf,IAAI,IAAI,GAAG,GAAG,GAAG,GAAG,CAAA;QACpB,IAAI,MAAM,GAAG,IAAI,CAAC,IAAI,CAAC,IAAI,GAAG,OAAO,CAAC,CAAA;QACtC,IAAI,IAAI,GAAG,IAAI,CAAC,KAAK,CAAC,IAAI,GAAG,MAAM,CAAC,CAAA;QACpC,MAAM,CAAC,GAAG,EAAE,GAAG,GAAG,IAAI,CAAC,CAAA;QACvB,GAAG,IAAI,IAAI,CAAA;IACf,CAAC;AACL,CAAC;AAGD,QAAe,CAAC,CAAC,UAAU,CAAI,OAAe,EAAE,GAAQ;IACpD,IAAI,GAAG,CAAC,MAAM,IAAI,OAAO,EAAE,CAAC;QACxB,MAAM,GAAG,CAAA;IACb,CAAC;SAAM,CAAC;QACJ,KAAK,IAAI,CAAC,GAAG,EAAE,GAAG,CAAC,IAAI,UAAU,CAAC,OAAO,EAAE,CAAC,EAAE,GAAG,CAAC,MAAM,CAAC,EAAE,CAAC;YACxD,MAAM,GAAG,CAAC,KAAK,CAAC,GAAG,EAAE,GAAG,CAAC,CAAA;QAC7B,CAAC;IACL,CAAC;AACL,CAAC;AAGM,KAAK,UAAU,iBAAiB,CAAO,OAAe,EAAE,KAAU,EAAE,GAAiC;IACxG,IAAI,KAAK,CAAC,MAAM,IAAI,OAAO;QAAE,OAAO,GAAG,CAAC,KAAK,CAAC,CAAA;IAE9C,IAAI,QAAQ,GAAmB,EAAE,CAAA;IACjC,KAAK,IAAI,KAAK,IAAI,UAAU,CAAC,OAAO,EAAE,KAAK,CAAC,EAAE,CAAC;QAC3C,QAAQ,CAAC,IAAI,CAAC,GAAG,CAAC,KAAK,CAAC,CAAC,CAAA;IAC7B,CAAC;IAED,IAAI,MAAM,GAAQ,EAAE,CAAA;IACpB,KAAK,IAAI,KAAK,IAAI,MAAM,OAAO,CAAC,GAAG,CAAC,QAAQ,CAAC,EAAE,CAAC;QAC5C,MAAM,CAAC,IAAI,CAAC,GAAG,KAAK,CAAC,CAAA;IACzB,CAAC;IACD,OAAO,MAAM,CAAA;AACjB,CAAC;AAGD,QAAe,CAAC,CAAC,WAAW,CAAO,KAAU,EAAE,KAAkB;IAC7D,IAAI,KAAK,CAAC,MAAM,IAAI,CAAC;QAAE,OAAM;IAC7B,IAAI,IAAI,GAAQ,CAAC,KAAK,CAAC,CAAC,CAAC,CAAC,CAAA;IAC1B,IAAI,SAAS,GAAG,KAAK,CAAC,KAAK,CAAC,CAAC,CAAC,CAAC,CAAA;IAC/B,KAAK,IAAI,CAAC,GAAG,CAAC,EAAE,CAAC,GAAG,KAAK,CAAC,MAAM,EAAE,CAAC,EAAE,EAAE,CAAC;QACpC,IAAI,IAAI,GAAG,KAAK,CAAC,CAAC,CAAC,CAAA;QACnB,IAAI,SAAS,GAAG,KAAK,CAAC,IAAI,CAAC,CAAA;QAC3B,IAAI,SAAS,KAAK,SAAS,EAAE,CAAC;YAC1B,IAAI,CAAC,IAAI,CAAC,IAAI,CAAC,CAAA;QACnB,CAAC;aAAM,CAAC;YACJ,MAAM,EAAC,KAAK,EAAE,IAAI,EAAE,KAAK,EAAE,SAAS,EAAC,CAAA;YACrC,IAAI,GAAG,CAAC,IAAI,CAAC,CAAA;YACb,SAAS,GAAG,SAAS,CAAA;QACzB,CAAC;IACL,CAAC;IACD,IAAI,IAAI,CAAC,MAAM,GAAG,CAAC,EAAE,CAAC;QAClB,MAAM,EAAC,KAAK,EAAE,IAAI,EAAE,KAAK,EAAE,SAAS,EAAC,CAAA;IACzC,CAAC;AACL,CAAC;AAGD,SAAgB,MAAM,CAAO,KAAU,EAAE,GAAM,EAAE,OAAoC;IACjF,IAAI,GAAG,GAAG,CAAC,CAAA;IACX,IAAI,GAAG,GAAG,KAAK,CAAC,MAAM,CAAA;IACtB,OAAO,GAAG,GAAG,GAAG,EAAE,CAAC;QACf,IAAI,IAAI,GAAG,GAAG,GAAG,GAAG,CAAA;QACpB,IAAI,GAAG,GAAG,GAAG,GAAG,CAAC,IAAI,GAAG,CAAC,IAAI,GAAG,CAAC,CAAC,CAAC,GAAG,CAAC,CAAA;QACvC,IAAI,EAAE,GAAG,KAAK,CAAC,GAAG,CAAC,CAAA;QACnB,IAAI,KAAK,GAAG,OAAO,CAAC,EAAE,EAAE,GAAG,CAAC,CAAA;QAC5B,IAAI,KAAK,IAAI,CAAC;YAAE,OAAO,GAAG,CAAA;QAC1B,IAAI,KAAK,GAAG,CAAC,EAAE,CAAC;YACZ,GAAG,GAAG,GAAG,CAAA;QACb,CAAC;aAAM,CAAC;YACJ,GAAG,GAAG,GAAG,GAAG,CAAC,CAAA;QACjB,CAAC;IACL,CAAC;IACD,OAAO,GAAG,CAAA;AACd,CAAC;AAGD,SAAgB,QAAQ,CAAsB,CAAgB;IAC1D,IAAI,KAAK,GAAG,IAAI,OAAO,EAAQ,CAAA;IAC/B,OAAO,UAAS,GAAM;QAClB,IAAI,GAAG,GAAG,KAAK,CAAC,GAAG,CAAC,GAAG,CAAC,CAAA;QACxB,IAAI,GAAG,KAAK,SAAS,EAAE,CAAC;YACpB,GAAG,GAAG,CAAC,CAAC,GAAG,CAAC,CAAA;YACZ,KAAK,CAAC,GAAG,CAAC,GAAG,EAAE,GAAG,CAAC,CAAA;QACvB,CAAC;QACD,OAAO,GAAG,CAAA;IACd,CAAC,CAAA;AACL,CAAC;AAGD,SAAgB,eAAe,CAAI,GAAQ,EAAE,IAAO;IAChD,IAAI,KAAK,GAAG,GAAG,CAAC,OAAO,CAAC,IAAI,CAAC,CAAA;IAC7B,IAAI,KAAK,GAAG,CAAC;QAAE,OAAM;IACrB,GAAG,CAAC,MAAM,CAAC,KAAK,EAAE,CAAC,CAAC,CAAA;AACxB,CAAC"}

lib/throttler.d.ts

 export declare class Throttler<T> {
     private fn;
     private interval;
-    private prefetch;
     private lastValue;
     private lastAccess;
     private pending?;
-    constructor(fn: () => Promise<T>, interval: number, prefetch?: boolean);
+    private prefetch;
+    constructor(fn: () => Promise<T>, interval: number);
+    enablePrefetch(): this;
+    disablePrefetch(): this;
     call(): Promise<T>;
@@ -10,0 +12,0 @@ get(): Promise<T>;

lib/throttler.d.ts.map

@@ -1,1 +0,1 @@
-{"version":3,"file":"throttler.d.ts","sourceRoot":"","sources":["../src/throttler.ts"],"names":[],"mappings":"AAGA,qBAAa,SAAS,CAAC,CAAC;IAMhB,OAAO,CAAC,EAAE;IACV,OAAO,CAAC,QAAQ;IAChB,OAAO,CAAC,QAAQ;IAPpB,OAAO,CAAC,SAAS,CAAI;IACrB,OAAO,CAAC,UAAU,CAAY;IAC9B,OAAO,CAAC,OAAO,CAAC,CAAY;gBAGhB,EAAE,EAAE,MAAM,OAAO,CAAC,CAAC,CAAC,EACpB,QAAQ,EAAE,MAAM,EAChB,QAAQ,UAAQ;IAG5B,IAAI,IAAI,OAAO,CAAC,CAAC,CAAC;IAMZ,GAAG,IAAI,OAAO,CAAC,CAAC,CAAC;IASvB,OAAO,CAAC,WAAW;YAWL,OAAO;CAQxB"}
+{"version":3,"file":"throttler.d.ts","sourceRoot":"","sources":["../src/throttler.ts"],"names":[],"mappings":"AAGA,qBAAa,SAAS,CAAC,CAAC;IAOhB,OAAO,CAAC,EAAE;IACV,OAAO,CAAC,QAAQ;IAPpB,OAAO,CAAC,SAAS,CAAI;IACrB,OAAO,CAAC,UAAU,CAAY;IAC9B,OAAO,CAAC,OAAO,CAAC,CAAY;IAC5B,OAAO,CAAC,QAAQ,CAAQ;gBAGZ,EAAE,EAAE,MAAM,OAAO,CAAC,CAAC,CAAC,EACpB,QAAQ,EAAE,MAAM;IAG5B,cAAc,IAAI,IAAI;IAKtB,eAAe,IAAI,IAAI;IAKvB,IAAI,IAAI,OAAO,CAAC,CAAC,CAAC;IAMZ,GAAG,IAAI,OAAO,CAAC,CAAC,CAAC;IASvB,OAAO,CAAC,WAAW;YAWL,OAAO;CAQxB"}

lib/throttler.js

@@ -6,8 +6,16 @@ "use strict";
 class Throttler {
-    constructor(fn, interval, prefetch = false) {
+    constructor(fn, interval) {
         this.fn = fn;
         this.interval = interval;
-        this.prefetch = prefetch;
         this.lastAccess = -Infinity;
+        this.prefetch = false;
     }
+    enablePrefetch() {
+        this.prefetch = true;
+        return this;
+    }
+    disablePrefetch() {
+        this.prefetch = false;
+        return this;
+    }
     call() {
@@ -14,0 +22,0 @@ if (this.pending)

lib/throttler.js.map

@@ -1,1 +0,1 @@
-{"version":3,"file":"throttler.js","sourceRoot":"","sources":["../src/throttler.ts"],"names":[],"mappings":";;;AAAA,iCAA2B;AAG3B,MAAa,SAAS;IAKlB,YACY,EAAoB,EACpB,QAAgB,EAChB,WAAW,KAAK;QAFhB,OAAE,GAAF,EAAE,CAAkB;QACpB,aAAQ,GAAR,QAAQ,CAAQ;QAChB,aAAQ,GAAR,QAAQ,CAAQ;QANpB,eAAU,GAAG,CAAC,QAAQ,CAAA;IAO3B,CAAC;IAEJ,IAAI;QACA,IAAI,IAAI,CAAC,OAAO;YAAE,OAAO,IAAI,CAAC,OAAO,CAAA;QACrC,IAAI,KAAK,GAAG,IAAI,CAAC,QAAQ,GAAG,IAAI,CAAC,GAAG,EAAE,GAAG,IAAI,CAAC,UAAU,CAAA;QACxD,OAAO,IAAI,CAAC,WAAW,CAAC,KAAK,CAAC,CAAA;IAClC,CAAC;IAED,KAAK,CAAC,GAAG;QACL,IAAI,GAAG,GAAG,IAAI,CAAC,GAAG,EAAE,CAAA;QACpB,IAAI,GAAG,GAAG,IAAI,CAAC,UAAU,GAAG,IAAI,CAAC,QAAQ,EAAE,CAAC;YACxC,OAAO,IAAI,CAAC,SAAS,CAAA;QACzB,CAAC;aAAM,CAAC;YACJ,OAAO,IAAI,CAAC,WAAW,CAAC,CAAC,CAAC,CAAA;QAC9B,CAAC;IACL,CAAC;IAEO,WAAW,CAAC,KAAa;QAC7B,IAAI,IAAI,CAAC,OAAO;YAAE,OAAO,IAAI,CAAC,OAAO,CAAA;QACrC,OAAO,IAAI,CAAC,OAAO,GAAG,IAAI,CAAC,OAAO,CAAC,KAAK,CAAC,CAAC,OAAO,CAAC,GAAG,EAAE;YACnD,IAAI,CAAC,OAAO,GAAG,SAAS,CAAA;YACxB,IAAI,IAAI,CAAC,QAAQ,EAAE,CAAC;gBAChB,IAAI,KAAK,GAAG,IAAI,CAAC,KAAK,CAAC,IAAI,CAAC,QAAQ,GAAG,GAAG,CAAC,CAAA;gBAC3C,IAAI,CAAC,WAAW,CAAC,KAAK,CAAC,CAAC,KAAK,CAAC,GAAG,EAAE,GAAE,CAAC,CAAC,CAAA;YAC3C,CAAC;QACL,CAAC,CAAC,CAAA;IACN,CAAC;IAEO,KAAK,CAAC,OAAO,CAAC,KAAa;QAC/B,IAAI,KAAK,GAAG,CAAC,EAAE,CAAC;YACZ,MAAM,IAAA,WAAI,EAAC,KAAK,CAAC,CAAA;QACrB,CAAC;QACD,IAAI,CAAC,SAAS,GAAG,MAAM,IAAI,CAAC,EAAE,EAAE,CAAA;QAChC,IAAI,CAAC,UAAU,GAAG,IAAI,CAAC,GAAG,EAAE,CAAA;QAC5B,OAAO,IAAI,CAAC,SAAS,CAAA;IACzB,CAAC;CACJ;AA7CD,8BA6CC"}
+{"version":3,"file":"throttler.js","sourceRoot":"","sources":["../src/throttler.ts"],"names":[],"mappings":";;;AAAA,iCAA2B;AAG3B,MAAa,SAAS;IAMlB,YACY,EAAoB,EACpB,QAAgB;QADhB,OAAE,GAAF,EAAE,CAAkB;QACpB,aAAQ,GAAR,QAAQ,CAAQ;QANpB,eAAU,GAAG,CAAC,QAAQ,CAAA;QAEtB,aAAQ,GAAG,KAAK,CAAA;IAKrB,CAAC;IAEJ,cAAc;QACV,IAAI,CAAC,QAAQ,GAAG,IAAI,CAAA;QACpB,OAAO,IAAI,CAAA;IACf,CAAC;IAED,eAAe;QACX,IAAI,CAAC,QAAQ,GAAG,KAAK,CAAA;QACrB,OAAO,IAAI,CAAA;IACf,CAAC;IAED,IAAI;QACA,IAAI,IAAI,CAAC,OAAO;YAAE,OAAO,IAAI,CAAC,OAAO,CAAA;QACrC,IAAI,KAAK,GAAG,IAAI,CAAC,QAAQ,GAAG,IAAI,CAAC,GAAG,EAAE,GAAG,IAAI,CAAC,UAAU,CAAA;QACxD,OAAO,IAAI,CAAC,WAAW,CAAC,KAAK,CAAC,CAAA;IAClC,CAAC;IAED,KAAK,CAAC,GAAG;QACL,IAAI,GAAG,GAAG,IAAI,CAAC,GAAG,EAAE,CAAA;QACpB,IAAI,GAAG,GAAG,IAAI,CAAC,UAAU,GAAG,IAAI,CAAC,QAAQ,EAAE,CAAC;YACxC,OAAO,IAAI,CAAC,SAAS,CAAA;QACzB,CAAC;aAAM,CAAC;YACJ,OAAO,IAAI,CAAC,WAAW,CAAC,CAAC,CAAC,CAAA;QAC9B,CAAC;IACL,CAAC;IAEO,WAAW,CAAC,KAAa;QAC7B,IAAI,IAAI,CAAC,OAAO;YAAE,OAAO,IAAI,CAAC,OAAO,CAAA;QACrC,OAAO,IAAI,CAAC,OAAO,GAAG,IAAI,CAAC,OAAO,CAAC,KAAK,CAAC,CAAC,OAAO,CAAC,GAAG,EAAE;YACnD,IAAI,CAAC,OAAO,GAAG,SAAS,CAAA;YACxB,IAAI,IAAI,CAAC,QAAQ,EAAE,CAAC;gBAChB,IAAI,KAAK,GAAG,IAAI,CAAC,KAAK,CAAC,IAAI,CAAC,QAAQ,GAAG,GAAG,CAAC,CAAA;gBAC3C,IAAI,CAAC,WAAW,CAAC,KAAK,CAAC,CAAC,KAAK,CAAC,GAAG,EAAE,GAAE,CAAC,CAAC,CAAA;YAC3C,CAAC;QACL,CAAC,CAAC,CAAA;IACN,CAAC;IAEO,KAAK,CAAC,OAAO,CAAC,KAAa;QAC/B,IAAI,KAAK,GAAG,CAAC,EAAE,CAAC;YACZ,MAAM,IAAA,WAAI,EAAC,KAAK,CAAC,CAAA;QACrB,CAAC;QACD,IAAI,CAAC,SAAS,GAAG,MAAM,IAAI,CAAC,EAAE,EAAE,CAAA;QAChC,IAAI,CAAC,UAAU,GAAG,IAAI,CAAC,GAAG,EAAE,CAAA;QAC5B,OAAO,IAAI,CAAC,SAAS,CAAA;IACzB,CAAC;CACJ;AAvDD,8BAuDC"}

package.json

 {
   "name": "@subsquid/util-internal",
-  "version": "3.3.0-portal-api.fff2e3",
+  "version": "3.3.0",
   "description": "Squid framework utilities for internal use",
   "license": "GPL-3.0-or-later",
-  "repository": "[e-mail]:subsquid/squid.git",
+  "repository": "[e-mail]:subsquid/squid-sdk.git",
   "publishConfig": {
@@ -16,4 +16,4 @@ "access": "public"
   "devDependencies": {
-    "@types/node": "^18.18.14",
-    "typescript": "~5.3.2"
+    "@types/node": "^24.0.0",
+    "typescript": "5.5.4"
   },
@@ -20,0 +20,0 @@ "scripts": {

src/async.ts

@@ -42,7 +42,7 @@ import assert from 'assert'
     private closed = false
-    private putFuture?: Future<void>
+    private putFutures: Future<void>[] = []
     private takeFuture?: Future<T | undefined>
     private closeListeners?: (() => void)[]
 
-    constructor(maxsize: number) {
+    constructor(private maxsize: number) {
         assert(maxsize >= 1)
@@ -58,5 +58,2 @@ this.buf = new Array(maxsize)
         if (this.closed) throw new ClosedQueueError()
-
-        assert(this.size < this.buf.length && this.putFuture == null, 'concurrent puts are not allowed')
-
         if (this.takeFuture) {
@@ -66,7 +63,11 @@ this.takeFuture.resolve(val)
         } else {
+            if (this.size == this.buf.length) {
+                this.enlargeBuffer()
+            }
             this.buf[(this.pos + this.size) % this.buf.length] = val
             this.size += 1
-            if (this.size == this.buf.length) {
-                this.putFuture = createFuture()
-                await this.putFuture.promise()
+            if (this.size >= this.maxsize) {
+                let fut = createFuture<void>()
+                this.putFutures.push(fut)
+                await fut.promise()
             }
@@ -76,2 +77,12 @@ }
 
+    private enlargeBuffer(): void {
+        let len = this.buf.length + 1
+        for (let i = this.size - this.pos; i < this.size; i++) {
+            let o = this.pos + i
+            this.buf[o % len] = this.buf[o % this.size]
+        }
+        this.buf[this.size % len] = undefined
+        assert(this.buf.length === len)
+    }
+
     forcePut(val: T): void {
@@ -100,5 +111,7 @@ if (this.closed) throw new ClosedQueueError()
             this.size -= 1
-            if (this.putFuture) {
-                this.putFuture.resolve()
-                this.putFuture = undefined
+            if (this.size < this.maxsize) {
+                for (let fut of this.putFutures) {
+                    fut.resolve()
+                }
+                this.putFutures.length = 0
             }
@@ -119,16 +132,10 @@ return val
 
-    async wait(): Promise<void> {
-        if (this.closed) throw new ClosedQueueError()
-        if (this.size < this.buf.length) return
-        assert(this.putFuture == null, 'concurrent puts and waits are not allowed')
-        this.putFuture = createFuture()
-        await this.putFuture.promise()
-    }
-
     close(): void {
         this.closed = true
-        if (this.putFuture) {
-            this.putFuture.reject(new ClosedQueueError())
-            this.putFuture = undefined
+
+        for (let fut of this.putFutures) {
+            fut.reject(new ClosedQueueError())
         }
+        this.putFutures.length = 0
+
         if (this.takeFuture) {
@@ -138,2 +145,3 @@ this.takeFuture.resolve(undefined)
         }
+
         if (this.closeListeners) {
@@ -156,2 +164,9 @@ for (let cb of this.closeListeners) {
 
+    removeCloseListener(cb: () => void): void {
+        if (this.closeListeners == null) return
+        let index = this.closeListeners.indexOf(cb)
+        if (index < 0) return
+        this.closeListeners.splice(index, 1)
+    }
+
     async *iterate(): AsyncIterable<T> {
@@ -173,5 +188,12 @@ try {
     concurrency: number,
-    stream: AsyncIterable<T>,
+    stream: AsyncIterable<T> | Iterable<T>,
     f: (val: T) => Promise<R>
 ): AsyncIterable<R> {
+    if (concurrency == 0) {
+        for await (let val of stream) {
+            yield await f(val)
+        }
+        return
+    }
+
     let queue = new AsyncQueue<{promise: Promise<R>}>(concurrency)
@@ -178,0 +200,0 @@

src/misc.ts

@@ -261,1 +261,8 @@ import assert from 'assert'
 }
+
+
+export function removeArrayItem<T>(arr: T[], item: T): void {
+    let index = arr.indexOf(item)
+    if (index < 0) return
+    arr.splice(index, 1)
+}

src/throttler.ts

@@ -8,9 +8,19 @@ import {wait} from './misc'
     private pending?: Promise<T>
+    private prefetch = false
 
     constructor(
         private fn: () => Promise<T>,
-        private interval: number,
-        private prefetch = false
+        private interval: number
     ) {}
 
+    enablePrefetch(): this {
+        this.prefetch = true
+        return this
+    }
+
+    disablePrefetch(): this {
+        this.prefetch = false
+        return this
+    }
+
     call(): Promise<T> {
@@ -17,0 +27,0 @@ if (this.pending) return this.pending

New alerts

No repository

Supply chain risk

Package does not have a linked source code repository. Without this field, a package will have no reference to the location of the source code use to generate the package.

Found 1 instance in 1 package

Fixed alerts

No repository

Supply chain risk

Package does not have a linked source code repository. Without this field, a package will have no reference to the location of the source code use to generate the package.

Found 1 instance in 1 package

No v1

Quality

Package is not semver >=1. This means it is not stable and does not support ^ ranges.

Found 1 instance in 1 package

Improved metrics

Total package byte prevSize

64670

4.07%

Lines of code

1270

5.75%

Number of low quality alerts

1

-50%

No dependency changes