import { type Meter } from "@opentelemetry/api";
import type { DisconnectedError, SyncMessage } from "cojson";
import type { Peer } from "cojson";
import { type CojsonInternalTypes } from "cojson";
import type { AnyWebSocket } from "./types.js";
export declare class BatchedOutgoingMessages implements CojsonInternalTypes.OutgoingPeerChannel {
    private websocket;
    private batching;
    /**
     * Additional key-value pair of attributes to add to the egress metric.
     */
    private meta?;
    private backlog;
    private queue;
    private processing;
    private closed;
    private egressBytesCounter;
    constructor(websocket: AnyWebSocket, batching: boolean, peerRole: Peer["role"], 
    /**
     * Additional key-value pair of attributes to add to the egress metric.
     */
    meta?: Record<string, string | number> | undefined, meter?: Meter);
    push(msg: SyncMessage | DisconnectedError): void;
    private processQueue;
    private processMessage;
    private serializeMessage;
    private appendMessage;
    private sendMessagesInBulk;
    drain(): void;
    setBatching(enabled: boolean): void;
    private closeListeners;
    onClose(callback: () => void): void;
    close(): void;
}
//# sourceMappingURL=BatchedOutgoingMessages.d.ts.map