import { Readable } from 'node:stream';
import type { Query } from '@google-cloud/datastore';
import type { CommonLogger } from '@naturalcycles/js-lib/log';
import type { ReadableTyped } from '@naturalcycles/nodejs-lib/stream';
import type { DatastoreDBStreamOptions } from './datastore.model.js';
export declare class DatastoreStreamReadable<T = any> extends Readable implements ReadableTyped<T> {
    private q;
    private logger;
    private readonly originalLimit;
    private rowsRetrieved;
    private endCursor?;
    private running;
    private done;
    private lastQueryDone?;
    private totalWait;
    private readonly table;
    /**
     * Used to support maxWait
     */
    private lastReadTimestamp;
    private readonly maxWaitInterval;
    private readonly opt;
    private readonly dsOpt;
    constructor(q: Query, opt: DatastoreDBStreamOptions, logger: CommonLogger);
    private runNextQuery;
    /**
     * Counts how many times _read was called.
     * For debugging.
     */
    count: number;
    _read(): void;
}