import * as WS from "./websocket";
import * as Rx from "rxjs";
import { ReceiveEvent, GatewayOpcode, GatewayPayload, Heartbeat, HelloEvent } from "../types";
export declare const opCode: <T = any>(code: GatewayOpcode) => (source: Rx.Observable<GatewayPayload<T>>) => Rx.Observable<GatewayPayload<T>>;
export type ConnectionPayload = WS.Payload<GatewayPayload>;
export declare function create(outgoing$: Rx.Observable<ConnectionPayload>, baseURL?: string): {
    setBaseUrl: (baseUrl: string) => void;
    raw$: Rx.Observable<GatewayPayload<any>>;
    dispatch$: Rx.Observable<GatewayPayload<ReceiveEvent>>;
    heartbeat$: Rx.Observable<GatewayPayload<Heartbeat>>;
    reconnect$: Rx.Observable<GatewayPayload<any>>;
    invalidSession$: Rx.Observable<GatewayPayload<boolean>>;
    hello$: Rx.Observable<GatewayPayload<HelloEvent>>;
    heartbeatAck$: Rx.Observable<GatewayPayload<undefined>>;
};
export type Connection = ReturnType<typeof create>;