import * as Rx from "rxjs";
import * as RL from "../rate-limits/rxjs";
import { Routes } from "../rest/client";
import * as Shard from "./shard";
import { SharderStore } from "./sharder/store";
export type CreateShard = (opts: {
    id: [number, number];
    baseURL: string;
    heartbeat?: () => void;
}) => Shard.Shard;
export interface Options {
    createShard: CreateShard;
    routes: Routes;
    shardConfig?: {
        /**
         * Array of shard IDs you want to start.
         */
        ids?: number[];
        /**
         * The total amount of shards across your entire system.
         *
         * Defaults to a number provider by Discord
         */
        count?: number;
    };
    store: SharderStore;
    rateLimit: RL.RateLimitOp;
    identifyLimit: number;
    identifyWindow: number;
}
export declare const spawn: ({ createShard, routes, shardConfig, store, rateLimit, identifyLimit, identifyWindow, }: Options) => Rx.Observable<{
    id: [number, number];
    conn: {
        setBaseUrl: (baseUrl: string) => void;
        raw$: Rx.Observable<import("../types").GatewayPayload<any>>;
        dispatch$: Rx.Observable<import("../types").GatewayPayload<import("../types").ReceiveEvent>>;
        heartbeat$: Rx.Observable<import("../types").GatewayPayload<import("../types").Heartbeat>>;
        reconnect$: Rx.Observable<import("../types").GatewayPayload<any>>;
        invalidSession$: Rx.Observable<import("../types").GatewayPayload<boolean>>;
        hello$: Rx.Observable<import("../types").GatewayPayload<import("../types").HelloEvent>>;
        heartbeatAck$: Rx.Observable<import("../types").GatewayPayload<undefined>>;
    };
    send: (payload: import("../types").GatewayPayload<any>) => void;
    reconnect: () => void;
    raw$: Rx.Observable<import("../types").GatewayPayload<any>>;
    dispatch$: Rx.Observable<import("../types").GatewayPayload<import("../types").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>;
}>;