import * as O from "fp-ts/Option";
import * as Rx from "rxjs";
import { ReceiveEvent, GatewayPayload, HelloEvent, InvalidSessionEvent, ReadyEvent, UpdatePresence } from "../types";
import { Connection } from "./connection";
import * as Dispatch from "./dispatch";
import { Options } from "./shard";
export declare const identify$: ({ conn, latestReady, latestSequence, token, intents, shard, presence, }: {
    token: string;
    conn: Connection;
    latestReady: Rx.Observable<O.Option<ReadyEvent>>;
    latestSequence: Rx.Observable<O.Option<number>>;
    presence?: UpdatePresence | undefined;
} & Pick<Options, "token" | "intents" | "shard">) => Rx.Observable<GatewayPayload<any>>;
export declare const heartbeats$: (conn: Connection, sequenceNumber: Rx.Observable<O.Option<number>>) => readonly [Rx.Observable<GatewayPayload<any>>, Rx.Observable<number>];
export declare const latestSequenceNumber: (dispatch$: Rx.Observable<GatewayPayload<ReceiveEvent>>) => Rx.Observable<O.Option<number>>;
export declare const latestReady: (fromDispatch: Dispatch.Dispatch, invalidSession$: Rx.Observable<GatewayPayload<InvalidSessionEvent>>) => Rx.Observable<O.Option<ReadyEvent>>;
export declare const heartbeatsFromHello: (hello$: Rx.Observable<GatewayPayload<HelloEvent>>) => Rx.Observable<number>;
export declare const heartbeatDiff: (heartbeats$: Rx.Observable<number>, heartbeatAck$: Rx.Observable<GatewayPayload>, hello$: Rx.Observable<GatewayPayload<HelloEvent>>) => Rx.Observable<number>;