import { Db } from "mongodb";
import { CursorDescription } from "./live_cursor";
import { OplogHandle } from "./oplog_tailing";
import { DocFetcher } from "./doc_fetcher";
import { ObserveCallbacks } from "./observe_multiplexer";
export declare class LiveMongoConnection {
    private client;
    db: Db;
    _oplogHandle: OplogHandle;
    _docFetcher: DocFetcher;
    private _observeMultiplexers;
    private _onFailoverHook;
    constructor(url: string, options?: any);
    close(): void;
    tail<T>(cursorDescription: CursorDescription<T>, docCallback: (doc: T) => void, timeoutMS?: number): {
        stop: () => void;
    };
    _observeChanges(cursorDescription: CursorDescription<any>, ordered: boolean, callbacks: ObserveCallbacks, nonMutatingCallbacks: boolean): Promise<{
        stop: () => void;
    }>;
    _observeChangesTailable(cursorDescription: CursorDescription<any>, ordered: boolean, callbacks: any): {
        stop: () => void;
    };
    _onFailover(callback: Function): {
        callback: any;
        stop: () => void;
    };
}