Method wshRpcCall

frontend/app/store/wshclient.ts:50–73

(command: string, data: any, opts: RpcOpts)

    }

    wshRpcCall(command: string, data: any, opts: RpcOpts): Promise<any> {
        const msg: RpcMessage = {
            command: command,
            data: data,
            source: this.routeId,
        };
        if (!opts?.noresponse) {
            msg.reqid = crypto.randomUUID();
        }
        if (opts?.timeout) {
            msg.timeout = opts.timeout;
        }
        if (opts?.route) {
            msg.route = opts.route;
        }
        const rpcGen = sendRpcCommand(this.openRpcs, msg);
        if (rpcGen == null) {
            return null;
        }
        const respMsgPromise = rpcGen.next(true); // pass true to force termination of rpc after 1 response (not streaming)
        return respMsgPromise.then((msg: IteratorResult<any, void>) => {
            return msg.value;
        });
    }

    wshRpcStream(command: string, data: any, opts: RpcOpts): AsyncGenerator<any, void, boolean> {
        if (opts?.noresponse) {