/** * read-queue.ts * * FIFO concurrency limiter for readRegion calls inside a worker. Caps how * many reads hold WASM result buffers at once (memory exhaustion guard) and * lets still-queued reads be cancelled before they start executing. */ /** Rejection used when a queued read is cancelled before it runs. */ export declare class ReadCancelledError extends Error { readonly code = "cancelled"; constructor(); } export declare class ReadQueue { private readonly maxConcurrent; private active; private waiters; constructor(maxConcurrent?: number); /** * Wait for a read slot. Resolves when the caller may start the read; * rejects with ReadCancelledError if cancelled while still queued. */ acquire(id: number): Promise; /** Release a slot acquired via acquire(). */ release(): void; /** * Cancel a read that is still waiting for a slot. Returns true if the * entry was found and rejected; false if it already started (or finished). */ cancel(id: number): boolean; } //# sourceMappingURL=read-queue.d.ts.map