import type { ServerRealtimeMessage } from '@xopcai/realtime-protocol';
import type { WebSocket } from 'ws';
export declare class RealtimeSocketWriter {
    private readonly socket;
    private readonly critical;
    private readonly normal;
    private queuedBytes;
    private sending;
    private closed;
    private retryTimer?;
    constructor(socket: WebSocket);
    enqueue(message: ServerRealtimeMessage, priority?: 'critical' | 'normal'): boolean;
    close(): void;
    private flush;
}