///
import { EventEmitter } from "events";
export declare class Changefeed extends EventEmitter {
private query;
private do_query;
private query_cancel;
private state;
private table;
private id;
private options;
private handle_update_queue;
constructor({ do_query, query_cancel, options, query, table, }: {
do_query: Function;
query_cancel: Function;
options: any;
table: string;
query: any;
});
connect(): Promise;
private process_queue_next_tick;
private run_the_query;
private handle_update;
close(): void;
private cancel_query;
get_state(): string;
}