Method clear

source/index.ts:616–645

Clear the queue.

()

	Clear the queue.
	*/
	clear(): void {
		for (const cleanupQueueAbortHandler of this.#queueAbortListenerCleanupFunctions) {
			cleanupQueueAbortHandler();
		}

		this.#queue = new this.#queueClass();

		// Clear interval timer since queue is now empty (consistent with #tryToStartAnother)
		this.#clearIntervalTimer();

		// Note: We preserve strict mode rate-limiting state (ticks and timeout)
		// because clear() only clears queued tasks, not rate limit history.
		// This ensures that rate limits are still enforced after clearing the queue.

		// Note: We don't clear #runningTasks as those tasks are still running
		// They will be removed when they complete in the finally block

		// Force synchronous update since clear() should have immediate effect
		this.#updateRateLimitState();

		// Emit events so waiters (onEmpty, onIdle, onSizeLessThan) can resolve
		this.emit('empty');

		if (this.#pending === 0) {
			this.#clearTimeoutTimer();
			this.emit('idle');
		}

		this.emit('next');
	}

	/**
	Can be called multiple times. Useful if you for example add additional items at a later time.