import type { GroupXEnvelope } from "../../core/envelope.js";
import type { OpenSseConnectionOptions, SseCloseCode, SseCloseInfo, SseConnectionSnapshot, SseDurableEventReader, SseRuntimeOptions } from "./types.js";
export declare class SseConnection {
    #private;
    readonly ready: Promise<void>;
    readonly closed: Promise<SseCloseInfo>;
    constructor(reader: SseDurableEventReader, options: OpenSseConnectionOptions, runtimeOptions: Required<SseRuntimeOptions>, onClosed: (connection: SseConnection) => void);
    /** Called by SseRuntime only after the connection has been registered. */
    start(): void;
    get roomId(): string;
    get isClosed(): boolean;
    snapshot(): SseConnectionSnapshot;
    receiveLive(envelope: GroupXEnvelope): void;
    close(code?: Extract<SseCloseCode, "client_closed" | "server_closed" | "aborted">): void;
}
export declare class SseRuntime {
    #private;
    constructor(reader: SseDurableEventReader, options?: SseRuntimeOptions);
    get connectionCount(): number;
    open(options: OpenSseConnectionOptions): SseConnection;
    publish(envelope: GroupXEnvelope): void;
    close(): void;
}
//# sourceMappingURL=runtime.d.ts.map