Class AsyncMutex

src/misc.ts:364–406

}

export class AsyncMutex {
	private locked = false;
	private resolverQueue: (() => void)[] = [];

	lock() {
		if (!this.locked) {
			// Fast path
			this.locked = true;
			return this.createLock(false, null);
		}

		const { promise, resolve } = promiseWithResolvers();
		this.resolverQueue.push(resolve);

		return this.createLock(true, promise);
	}

	private createLock(pending: boolean, ready: Promise<void> | null): AsyncMutexLock {
		let released = false;

		return {
			pending,
			ready,
			release: () => {
				if (released) return;
				released = true;
				this.dispatch();
			},
			[Symbol.dispose]() {
				this.release();
			},
		};
	}

	private dispatch() {
		if (this.resolverQueue.length > 0) {
			const resolve = this.resolverQueue.shift()!;
			resolve();
		} else {
			this.locked = false;
		}
	}
}

export class Bitstream {
	/** Current offset in bits. */