import { Observable } from "rxjs";
import * as M from "../model";
export type Any = any;
export type Omit<T, K extends keyof T> = Pick<T, Exclude<keyof T, K>>;
export type Unpacked<T> = T extends Promise<infer U2> ? U2 : T extends Observable<infer U3> ? U3 : T;
export type DropFunctionsContext<T> = {
    [K in keyof T]: T[K] extends (this: infer THIS, ...args: infer A) => infer R ? (this: void, ...args: A) => R : never;
};
export type PayloadUid = string;
interface PayloadBase<AD extends M.ApiDefinition<AD>> {
    uid: PayloadUid;
    name: keyof M.Actions<AD>;
}
export type PayloadRequest<AD extends M.ApiDefinition<AD>> = PayloadBase<AD> & (({
    type: "request";
    args: Parameters<M.Actions<AD>[keyof M.Actions<AD>]>;
} & Pick<M.CallOptions<AD>, "serialization">) | ({
    type: "unsubscribe-request";
    reason: "finish promise" | "timeout";
}));
export type PayloadResponse<AD extends M.ApiDefinition<AD>> = PayloadBase<AD> & ({
    type: "response";
}) & ({
    data: Unpacked<ReturnType<M.Actions<AD>[keyof M.Actions<AD>]>>;
} | {
    complete: true;
} | {
    error: Any;
});
export type Payload<AD extends M.ApiDefinition<AD>> = PayloadRequest<AD> | PayloadResponse<AD>;
export type DefACA = Any[];
export declare const MODULE_NAME = "pubsub-to-rpc-api";
export declare const ONE_SECOND_MS = 1000;
export declare const EMPTY_FN: M.LoggerFn;
export type InternalLogger = M.Logger & {
    _private: true;
};
export declare const LOG_STUB: Readonly<InternalLogger>;
export declare const NOTIFICATION_WRAPPER_STUB: Required<M.CallOptions<Any>>["notificationWrapper"];
export declare const ON_EVENT_LISTENER_DEFAULT_PAYLOAD_ARG_INDEX = 0;
export type Impossible<K extends keyof Any> = {
    [P in K]: never;
};
export type NoExtraProperties<T, U extends T = T> = U & Impossible<Exclude<keyof U, keyof T>>;
export {};