import { Observable } from 'rxjs';
import { MqttConnect } from '../mqtt/IMqttClient';
import { IConnection, CloudMessage } from './IConnection';
export declare class Connection implements IConnection {
    token: string;
    messages: Observable<CloudMessage>;
    private _client;
    private get client();
    private set client(value);
    static From(host: string, port: string | number, token: string, mqttConnect: MqttConnect): Promise<IConnection>;
    on(event: any, cb: any): IConnection;
    end(force?: boolean, opts?: Record<string, any>, cb?: Function): IConnection;
    reconnect(opts?: object): IConnection;
    unsubscribe(topic: string | string[], opts?: any, callback?: any): IConnection;
    publish(topic: any, message: any, opts?: any, callback?: any): IConnection;
    subscribe(topic: any, callback?: any): IConnection;
    private messagesFrom;
}