import { LiveMongoConnection } from "./live_connection";
import { ObserveMultiplexer } from "./observe_multiplexer";
import { CursorDescription } from "./live_cursor";
interface PollingObserveDriverOptions<TOrdered extends boolean> {
    cursorDescription: CursorDescription<any>;
    mongoHandle: LiveMongoConnection;
    ordered: TOrdered;
    multiplexer: ObserveMultiplexer;
    stopCallbacks?: (() => void)[];
    matcher?: any;
    sorter?: any;
}
export declare class PollingObserveDriver<TOrdered extends boolean> {
    private _cursorDescription;
    private _mongoHandle;
    private _ordered;
    private _multiplexer;
    private _stopCallbacks;
    private _stopped;
    private _results;
    private _pollsScheduledButNotStarted;
    private _pendingWrites;
    private _ensurePollIsScheduled;
    private _taskQueue;
    constructor(options: PollingObserveDriverOptions<TOrdered>);
    _unthrottledEnsurePollIsScheduled(): void;
    _pollMongo(): Promise<void>;
    stop(): void;
}
export {};