import { Adapter, Context, ContextualArgs, Dispatch, MaybeContextualArg, PreparedStatement } from "@decaf-ts/core";
import { HttpConfig, HttpFlags } from "./types.d.mts";
export declare class HttpDispatcher extends Dispatch<Adapter<HttpConfig, any, PreparedStatement<any>, Context<HttpFlags>>> {
    private connector?;
    private removeConnectorListener?;
    private subscriptionId?;
    private subscriptionSync?;
    private lastSubscriptionSignature?;
    protected initialized: boolean;
    private listening;
    /**
     * Called by the base Dispatch after observe(adapter).
     * We patch the Adapter's internal ObserverHandler to track how many observers exist.
     */
    protected initialize(...args: MaybeContextualArg<any>): Promise<void>;
    /**
     * Enables the dispatcher. SSE will only open and start to listening for events if there is at least one observer.
     */
    startListening(...args: ContextualArgs<any>): Promise<void>;
    syncSubscriptions(force?: boolean): Promise<void>;
    private ensureSubscriptionId;
    private appendQuery;
    private currentSubscriptionTopics;
    private topicForObserver;
    private buildEventBaseUrl;
    private syncSubscriptionsInternal;
    private clearSubscriptionRegistration;
    private resolveEventHeaders;
    close(...args: ContextualArgs<Context<HttpFlags>>): Promise<void>;
}