import { Subscription } from "../ddp/subscription";
import * as MongoDB from "mongodb";
import { LiveMongoConnection } from "./live_connection";
interface CustomFindOptions<T> extends MongoDB.FindOptions<MongoDB.WithId<T>> {
    pollingThrottleMs?: number;
    pollingIntervalMs?: number;
    transform?: (doc: T) => T;
    maxTimeMs?: number;
    disableOplog?: boolean;
}
export declare class CursorDescription<T> {
    collectionName: string;
    selector: MongoDB.Filter<MongoDB.WithId<T>>;
    options: CustomFindOptions<MongoDB.WithId<T>>;
    constructor(collectionName: string, selector: MongoDB.Filter<MongoDB.WithId<T>>, options?: CustomFindOptions<MongoDB.WithId<T>>);
}
export declare class LiveCursor<T> {
    mongo: LiveMongoConnection;
    cursorDescription: CursorDescription<T>;
    constructor(mongo: LiveMongoConnection, collectionName: string, selector: MongoDB.Filter<MongoDB.WithId<T>>, options: CustomFindOptions<MongoDB.WithId<T>>);
    _publishCursor(sub: Subscription): Promise<{
        stop: () => void;
    }>;
}
export {};