import { Cache } from "@peerbit/cache";
import { CollectNextRequest, type IterationRequest, type SearchRequest, type SearchRequestIndexed } from "@peerbit/document-interface";
import type * as indexerTypes from "@peerbit/indexer-interface";
export declare class ResumableIterators<T extends Record<string, any>> {
    readonly index: indexerTypes.Index<T>;
    readonly queues: Cache<{
        iterator: indexerTypes.IndexIterator<T, undefined>;
        request: SearchRequest | SearchRequestIndexed | IterationRequest;
        keepAlive: boolean;
    }>;
    constructor(index: indexerTypes.Index<T>, queues?: Cache<{
        iterator: indexerTypes.IndexIterator<T, undefined>;
        request: SearchRequest | SearchRequestIndexed | IterationRequest;
        keepAlive: boolean;
    }>);
    iterateAndFetch(request: SearchRequest | SearchRequestIndexed | IterationRequest, options?: {
        keepAlive?: boolean;
    }): Promise<indexerTypes.IndexedResults<T>>;
    next(request: SearchRequest | SearchRequestIndexed | IterationRequest | CollectNextRequest, options?: {
        keepAlive?: boolean;
    }): Promise<indexerTypes.IndexedResults<T>>;
    close(close: {
        idString: string;
    }): void;
    private clear;
    clearAll(): Promise<void>;
    has(id: string): boolean;
    getPending(id: string): Promise<number | undefined>;
}
//# sourceMappingURL=resumable-iterator.d.ts.map