import type { LazyService } from "./lazy-service";
export interface LazyRegistration<TContext, TEvent> {
    id: string;
    event: string;
    service: LazyService<{
        handle(event: TEvent, context: TContext): void | Promise<void>;
    }>;
    delivery: "await" | "buffer";
}
export interface LazyRegistrationDispatcherOptions {
    maxBufferedPerRegistration?: number;
    /** Dropped buffered events resolve without delivery after this callback, when provided. */
    onDropped?(info: {
        registrationId: string;
        event: string;
        droppedCount: number;
    }): void;
}
export declare function createLazyRegistrationDispatcher<TContext, TEvent>(opts?: LazyRegistrationDispatcherOptions): {
    register(reg: LazyRegistration<TContext, TEvent>): () => void;
    dispatch(event: string, payload: TEvent, context: TContext): Promise<void>;
    dispose(): Promise<void>;
};