import { BehaviorSubject, Observable } from 'rxjs';
import { DCDataModel, IndexedDataSet } from "./DCDataModel";
import { IDCSchema } from "./IDCSchema";
import { IDCDataExchange } from "./IDCDataExchange";
import { DCSerializable, IDCSerializable, IDCSerializableClass } from "./DCSerializable";
export interface IWebSocket {
    addEventListener(event: string, eventCallback: (event: any) => void): any;
    send(data: string): any;
}
export declare class DCWebSocketDataService {
    protected dataModel: DCDataModel;
    schema: IDCSchema;
    protected dataChange$: BehaviorSubject<boolean>;
    protected idSearches: {
        [partialId: string]: Observable<string[]>;
    };
    protected dataRequested: {
        [tableName: string]: boolean;
    };
    protected itemsFetched: {
        [id: string]: boolean;
    };
    protected socketIsReady: boolean;
    protected requestQueue: IDCDataExchange[];
    protected activeRequests: {
        [id: string]: BehaviorSubject<IDCDataExchange>;
    };
    completedExchanges: IDCDataExchange[];
    protected throwErrors: boolean;
    private socket;
    debug: (msg: any) => void;
    constructor(classList: IDCSerializableClass[], modelVersion: string, socket: IWebSocket, debug?: (msg: any) => void);
    addItem(sObj: DCSerializable): Observable<IDCDataExchange>;
    deleteItem(obj: DCSerializable): Observable<IDCDataExchange>;
    fetchItem(id: string, table?: string): Observable<DCSerializable>;
    fetchItemRecursive(id: string, table?: string): Observable<DCSerializable>;
    /**
     * Track the items that have been checked
     * @param id
     * @param table
     * @param checkedIds[]  An array of object ids that have already been processed under the current call
     */
    private fetchItemRecursiveKernel;
    fetchTable(table: string): Observable<IDCDataExchange>;
    getItem(id: string): DCSerializable;
    getItemMatches(partialId: string): Observable<string[]>;
    getItemObservable(id: string, table?: string): Observable<DCSerializable>;
    getNewItem(table: string): DCSerializable;
    getNewItemT<T extends DCSerializable>(table: typeof DCSerializable): T;
    getShortId(guid: string): string;
    getTable(table: string): IndexedDataSet<DCSerializable>;
    getTableObservableArray(table: string): Observable<DCSerializable[]>;
    getTableSerialized(table: string): IndexedDataSet<IDCSerializable>;
    processServerData(data: any): void;
    sendExchange(obj: IDCDataExchange): Observable<IDCDataExchange>;
    protected socketSetup(socket: IWebSocket): void;
    updateItem(obj: DCSerializable): Observable<IDCDataExchange>;
}