/**
 * Asynchronous queue for managing snapshot updates
 *
 * This queue enables sequential processing of real-time snapshot updates,
 * allowing producers (snapshot listeners) and consumers (async generators)
 * to work at different rates without blocking.
 */
export declare class AsyncQueue<T> {
    private queue;
    private resolvers;
    /**
     * Adds an item to the queue
     *
     * If there are pending dequeuers waiting, immediately resolves the first one.
     * Otherwise, adds the item to the queue for later consumption.
     *
     * @param item - Item to enqueue
     * @example
     * const queue = new AsyncQueue<string>();
     * queue.enqueue('item1');
     * queue.enqueue('item2');
     */
    enqueue(item: T): void;
    /**
     * Removes and returns an item from the queue
     *
     * If the queue is empty, returns a promise that resolves when the next
     * item is enqueued. This enables async iteration over a stream of items.
     *
     * @returns Promise that resolves to the next item
     * @example
     * const queue = new AsyncQueue<string>();
     * queue.enqueue('item1');
     * const item = await queue.dequeue(); // 'item1'
     */
    dequeue(): Promise<T>;
    /**
     * Gets the current number of items in the queue
     *
     * Note: Does not include pending dequeue operations waiting for items.
     */
    get length(): number;
    /**
     * Clears all items from the queue and cancels pending dequeue operations
     */
    clear(): void;
}
//# sourceMappingURL=async-queue.d.ts.map