Method callApi

src/client/ws/WsClient.ts:164–244

(apiName: T, req: ServiceType['req'][T], options: TransportOptions = {})

        [sn: number]: { rs: (data: any) => void, rj: (err: any) => void } | undefined;
    } = {};
    callApi<T extends keyof ServiceType['req']>(apiName: T, req: ServiceType['req'][T], options: TransportOptions = {}): SuperPromise<ServiceType['res'][T], TsrpcError> {
        let sn = this._apiReqSnCounter.getNext();
        this.logger.log(`[ApiReq] #${sn}`, apiName, req);

        if (!this._ws) {
            throw new Error('Not connected')
        }

        // GetService
        let service = this.serviceMap.apiName2Service[apiName as string];
        if (!service) {
            throw new Error('Invalid api name: ' + apiName);
        }

        // Encode        
        let buf = TransportDataUtil.encodeApiReq(this.tsbuffer, service, req, sn);

        // Wait Res
        let promise = new SuperPromise<ServiceType['res'][T], TsrpcError>((rs, rj) => {
            this._pendingApi[sn] = {
                rs: rs,
                rj: rj
            }
        });

        // Send
        this._ws.send(buf, err => {
            if (err) {
                this.logger.error('WebSocket Send Error:', err);
                this._pendingApi[sn] && this._pendingApi[sn]!.rj(new TsrpcError('Network Error', {
                    code: (err as any).code,
                    isNetworkError: true,
                    innerError: err
                }))
            }
        });

        // onCancel
        promise.onCancel(() => {
            this.logger.log(`[ApiCancel] #${sn}`);
        })

        // Timeout
        let timeout = options.timeout !== undefined ? options.timeout : this.options.timeout;
        let timeoutTimer: ReturnType<typeof setTimeout> | undefined;
        let clear = () => {
            if (timeoutTimer) {
                clearTimeout(timeoutTimer);
                timeoutTimer = undefined;
            }
            if (this._pendingApi[sn]) {
                delete this._pendingApi[sn];
            }
        }
        if (timeout > 0) {
            timeoutTimer = setTimeout(() => {
                if (this._pendingApi[sn]) {
                    this.logger.log(`[ApiTimeout] #${sn}`);