import { Subject } from 'rxjs'; import type { RequestData, ResponseData } from './trpc'; export declare const clientFunctionCallEventSubjectMap: Map>; /** * Clear client function call event subjects. * If socketId is not undefined or 0, clear all the client function call event subjects. * Otherwise, clear the client function call event subjects by socketId. * @param socketId The id of socket. */ export declare const clearClientFunctionCallEventSubjects: (socketId?: number) => void; /** * Get a client function call event subject by socketId. * If there is no cached subject which key is socketId, create an new subject, cache it with socketId and return it. * @param socketId The id of socket. * @returns The cached subject which key is socketId. */ export declare const getClientFunctionCallEventSubject: (socketId: number) => Subject; export declare const clientFunctionReturnEventSubject: Subject;