import { IConnector } from "../../IConnector";
import { ConnectorOptions } from "../../../models/PushClientOptions";
import { Socket } from "socket.io-client";
import { PublishRequest } from "../../../models/requests/PublishRequest";
import { PushServerResponse } from "../../../models/PushServerResponse";
import { SubscribeRequest } from "../../../models/requests/SubscribeRequest";
import { UnsubscribeRequest } from "../../../models/requests/UnsubscribeRequest";
import { PullRequest } from "../../../models/requests/PullRequest";
import { StatusRequest } from "../../../models/requests/StatusRequest";
import { Logger } from "../../../utils/LoggerUtil";
import { CountRequest } from "../../../models/requests/CountRequest";
import { CallbackNetworkStatusListener } from "../../../models/callbacks/NetworkStatusListener";
/**
 * 	@class
 */
export declare class WebsocketConnector implements IConnector {
    /**
     * 	push client options
     */
    options: ConnectorOptions;
    /**
     * 	client socket
     */
    socket: Socket;
    /**
     * 	hello interval
     */
    helloInterval: any;
    /**
     * 	network status listener
     */
    callbackNetworkStatusListener: CallbackNetworkStatusListener;
    /**
     *	log
     */
    log: Logger;
    constructor(options: ConnectorOptions);
    /**
     * 	setup
     *	@private
     *	@returns {void}
     */
    private setupEvents;
    /**
     * 	hello thread
     *	@private
     */
    private setupHelloThread;
    /**
     *	set up a callback function to listen for the network status changes
     *
     * 	@implements
     * 	@param callback		{CallbackNetworkStatusListener}
     * 	@returns { void }
     */
    setNetworkStatusListener(callback: CallbackNetworkStatusListener): void;
    /**
     * 	wait until the client connected to server successfully
     *
     * 	@implements
     *	@param timeout	{number} timeout in milliseconds
     *	@returns {Promise< void >}
     */
    waitUntilConnected(timeout: number): Promise<void>;
    /**
     * 	close the connection to server
     */
    close(): void;
    /**
     * 	@implements
     *	@param publishRequest	{PublishRequest}
     *	@returns {Promise< PushServerResponse >}
     */
    publish(publishRequest: PublishRequest): Promise<PushServerResponse>;
    /**
     * 	@implements
     *	@param subscribeRequest		{SubscribeRequest}
     *	@returns {Promise< PushServerResponse >}
     */
    subscribe(subscribeRequest: SubscribeRequest): Promise<PushServerResponse>;
    /**
     * 	@implements
     *	@param unsubscribeRequest	{UnsubscribeRequest}
     *	@returns {Promise< PushServerResponse >}
     */
    unsubscribe(unsubscribeRequest: UnsubscribeRequest): Promise<PushServerResponse>;
    /**
     * 	@implements
     *	@param statusRequest	{StatusRequest}
     *	@returns {Promise< PushServerResponse >}
     */
    status(statusRequest: StatusRequest): Promise<PushServerResponse>;
    /**
     * 	@implements
     *	@param pullRequest	{PullRequest}
     *	@returns {Promise< PushServerResponse >}
     */
    pull(pullRequest: PullRequest): Promise<PushServerResponse>;
    /**
     * 	@implements
     *	@param countRequest	{CountRequest}
     *	@returns {Promise< PushServerResponse >}
     */
    count(countRequest: CountRequest): Promise<PushServerResponse>;
    /**
     *	send event
     *
     *	@param eventName	{string}
     *	@param arg		{any}
     *	@param [retry]		{number}
     *	@returns {Promise<any>}
     */
    send(eventName: string, arg: any, retry?: number): Promise<any>;
}
//# sourceMappingURL=WebsocketConnector.d.ts.map