import * as Rx from "rxjs";
import * as Store from "../rate-limits/store";
import { ReceiveEvent, GatewayPayload, UpdatePresence } from "../types";
import * as Dispatch from "./dispatch";
import * as Sharder from "./sharder";
export interface Options {
    token: string;
    /** Override gateway handling with custom payload source */
    payloads$?: Rx.Observable<GatewayPayload>;
    rateLimits?: {
        store: Store.Store;
        identifyLimit?: number;
        identifyWindow?: number;
        sendLimit?: number;
        sendWindow?: number;
    };
    /**
     * Bitfield of the gateway intents you want to subscribe to.
     * `Intents.GUILDS` is always enabled.
     */
    intents?: number;
    /**
     * Set the initial presence
     */
    presence?: UpdatePresence;
    shardConfig?: Sharder.Options["shardConfig"];
    sharderStore?: Sharder.Options["store"];
}
/** A client is one or more shards */
export declare const create: (routes: import("../types").Endpoints<import("axios").AxiosRequestConfig<any>>) => ({ token, intents, rateLimits: { store: rateLimitStore, identifyLimit, identifyWindow, ...shardRateLimits }, shardConfig, sharderStore, presence, }: Options) => {
    raw$: Rx.Observable<GatewayPayload<any>>;
    dispatch$: Rx.Observable<GatewayPayload<ReceiveEvent>>;
    fromDispatch: Dispatch.Dispatch;
    fromDispatchWithShard: Dispatch.DispatchWithShard;
    latestDispatch: Dispatch.Dispatch;
    shards$: Rx.Observable<{
        id: [number, number];
        conn: {
            setBaseUrl: (baseUrl: string) => void;
            raw$: Rx.Observable<GatewayPayload<any>>;
            dispatch$: Rx.Observable<GatewayPayload<ReceiveEvent>>;
            heartbeat$: Rx.Observable<GatewayPayload<import("../types").Heartbeat>>;
            reconnect$: Rx.Observable<GatewayPayload<any>>;
            invalidSession$: Rx.Observable<GatewayPayload<boolean>>;
            hello$: Rx.Observable<GatewayPayload<import("../types").HelloEvent>>;
            heartbeatAck$: Rx.Observable<GatewayPayload<undefined>>;
        };
        send: (payload: GatewayPayload<any>) => void;
        reconnect: () => void;
        raw$: Rx.Observable<GatewayPayload<any>>;
        dispatch$: Rx.Observable<GatewayPayload<ReceiveEvent>>;
        ready$: Rx.Observable<import("fp-ts/lib/Option").Option<import("../types").ReadyEvent>>;
        latency$: Rx.Observable<number>;
        effects$: Rx.Observable<never>;
        debug$: Rx.Observable<never>;
    }>;
    shardsReady$: Rx.Observable<void>;
    debug$: Rx.Observable<never>;
};
export type Client = ReturnType<ReturnType<typeof create>>;
export declare const createFromPayloads: (incoming$: Rx.Observable<GatewayPayload>) => Client;