import { Query } from 'mingo';
import { Document, Filter } from 'mongodb';
import type { ErrorEvents } from './ErrorEvents';
import { PromiseTracker } from './PromiseTracker';
import { TypedEventEmitter } from './TypedEventEmitter';
export interface SubscriptionOptions<TMessage extends Document> {
    /** Local filter to apply on received messages (in-memory). */
    filter?: Filter<TMessage>;
}
export type SubscriptionCallback<TMessage extends Document> = (message: TMessage) => void | Promise<void>;
export type SubscriptionEvents<TMessage extends Document> = ErrorEvents<TMessage>;
export declare class Subscription<TMessage extends Document> extends TypedEventEmitter<SubscriptionEvents<TMessage>> {
    protected callback: SubscriptionCallback<TMessage>;
    protected filter?: Filter<TMessage>;
    protected mingoQuery?: Query;
    protected promises: PromiseTracker;
    protected closed: boolean;
    constructor(callback: SubscriptionCallback<TMessage>, options?: SubscriptionOptions<TMessage>);
    close(): Promise<void>;
    handle(message: TMessage): Promise<void>;
}