import DoubleEndedQueue from "double-ended-queue";
import { StreamServerSocket } from "./stream_server";
import { DDPServer } from "./livedata_server";
import { SessionCollectionView } from "./session-collection-view";
import { SubscriptionHandle } from "./subscription";
import { OrderedDict } from "../ordered-dict/ordered_dict";
export interface SessionConnectionHandle {
    id: string;
    close: Function;
    onClose: Function;
    clientAddress: string | null;
    httpHeaders: Record<string, any>;
    sockjsSessionId?: string;
}
interface DDPMessage {
    msg: string;
    id: string;
    version?: string;
    name?: string;
    method?: string;
    params?: any[];
    randomSeed?: any;
}
export declare class DDPSession {
    id: string;
    server: DDPServer;
    inQueue: DoubleEndedQueue<any>;
    userId: string | null;
    connectionHandle: SessionConnectionHandle;
    _dontStartNewUniversalSubs: boolean;
    _socketUrl: string;
    version: string;
    private socket;
    private initialized;
    private workerRunning;
    private _namedSubs;
    private _universalSubs;
    private collectionViews;
    private _isSending;
    private _pendingReady;
    private _closeCallbacks;
    private _respondToPings;
    private heartbeat;
    constructor(server: DDPServer, version: string, socket: StreamServerSocket, options: any);
    sendReady(subscriptionIds: string[]): void;
    _canSend(collectionName: any): boolean;
    sendInitialAdds(collectionName: string, docs: Map<string, any> | OrderedDict): void;
    sendAdded(collectionName: string, id: string, fields: Record<string, any>): void;
    sendChanged(collectionName: string, id: string, fields: Record<string, any>): void;
    sendRemoved(collectionName: string, id: string): void;
    getSendCallbacks(): {
        added: any;
        changed: any;
        removed: any;
    };
    getCollectionView(collectionName: string): SessionCollectionView;
    initialAdds(subscriptionHandle: SubscriptionHandle, collectionName: string, docs: Map<string, any> | OrderedDict): void;
    added(subscriptionHandle: SubscriptionHandle, collectionName: string, id: string, fields: Record<string, any>): void;
    removed(subscriptionHandle: SubscriptionHandle, collectionName: string, id: string): void;
    changed(subscriptionHandle: SubscriptionHandle, collectionName: string, id: string, fields: Record<string, any>): void;
    startUniversalSubs(): void;
    close(): void;
    send(msg: any): void;
    sendError(reason: any, offendingMessage: any): void;
    processMessage(msg_in: DDPMessage): Promise<void>;
    private protocol_handlers;
    _eachSub(f: any): void;
    _diffCollectionViews(beforeCVs: any): void;
    _setUserId(userId: any): void;
    _startSubscription(handler: any, subId?: any, params?: any, name?: any): Promise<void>;
    _stopSubscription(subId: any, error?: any): void;
    _deactivateAllSubscriptions(): void;
    _clientAddress(): string;
}
export {};