import { DDPClient, DDPCacheEngine } from '../';
export declare enum MY_DDP_COLLECTIONS {
    USERS = "users",
    CHATS = "chats"
}
export interface IUser {
    _id: string;
    full_name: string;
    email: string;
}
/**
 * DDP Client implementation
 * Handle connection, login and collections subscriptions
 */
export declare class MyDDPClient extends DDPClient {
    ddpStatus: {
        isConnected: boolean;
        isDisconnected: boolean;
    };
    constructor();
    initCacheStorage(cacheEngine: DDPCacheEngine): void;
    connect(): void;
    login(): Promise<any>;
    logout(): void;
    onConnected(): void;
    onDisconnected(): void;
    onSocketError(error: any): void;
    onSocketClosed(): void;
    onMessage(data: any): void;
    subscribePublications(): void;
    observeCollections(): void;
    getCollectionData$(collectionName: MY_DDP_COLLECTIONS): import("rxjs/internal/Observable").Observable<any>;
}