import { type FastifyReply, type FastifyRequest } from "fastify";
import { type z } from "zod";
export declare function createSSEFactory<T extends z.ZodObject>(socket: FastifyRequest["socket"], reply: FastifyReply, _events: T): SSEConnection<T>;
export declare function createMockSSEFactory<T extends z.ZodObject>(_events: T): SSEConnection<T>;
export interface SSEConnection<T extends z.ZodObject> {
    get closed(): boolean;
    onClose(callback: () => void): void;
    publish<K extends keyof z.infer<T>>(event: K, data: z.infer<T>[K]): void;
    end(): Promise<void>;
}
//# sourceMappingURL=sse.d.ts.map