Method wshRpcStream

frontend/app/store/wshclient.ts:75–93

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

    }

    wshRpcStream(command: string, data: any, opts: RpcOpts): AsyncGenerator<any, void, boolean> {
        if (opts?.noresponse) {
            throw new Error("noresponse not supported for responsestream calls");
        }
        const msg: RpcMessage = {
            command: command,
            data: data,
            reqid: crypto.randomUUID(),
            source: this.routeId,
        };
        if (opts?.timeout) {
            msg.timeout = opts.timeout;
        }
        if (opts?.route) {
            msg.route = opts.route;
        }
        const rpcGen = sendRpcCommand(this.openRpcs, msg);
        return rpcGen;
    }

    async handleIncomingCommand(msg: RpcMessage) {
        // TODO implement a timeout (setTimeout + sendResponse)