import * as Rx from "rxjs";
import { ReceiveEvents, GatewayPayload } from "../types";
import { Shard } from "./shard";
export type Dispatch = <E extends keyof ReceiveEvents>(event: E) => Rx.Observable<ReceiveEvents[E]>;
export type DispatchWithShard = <E extends keyof ReceiveEvents>(event: E) => Rx.Observable<readonly [ReceiveEvents[E], Shard]>;
export declare const listen: (source$: Rx.Observable<any>) => Dispatch;
export declare const listenWithShard: (source$: Rx.Observable<readonly [GatewayPayload, Shard]>) => DispatchWithShard;
export declare const latest: (fromDispatch: Dispatch) => Dispatch;