(
openRpcs: Map<string, ClientRpcEntry>,
msg: RpcMessage
)
| 81 | } |
| 82 | |
| 83 | function sendRpcCommand( |
| 84 | openRpcs: Map<string, ClientRpcEntry>, |
| 85 | msg: RpcMessage |
| 86 | ): AsyncGenerator<RpcMessage, void, boolean> { |
| 87 | DefaultRouter.recvRpcMessage(msg); |
| 88 | if (msg.reqid == null) { |
| 89 | return null; |
| 90 | } |
| 91 | const rtnGen = rpcResponseGenerator(openRpcs, msg.command, msg.reqid, msg.timeout); |
| 92 | rtnGen.next(); |
| 93 | return rtnGen; |
| 94 | } |
| 95 | |
| 96 | async function consumeGenerator(gen: AsyncGenerator<any, any, any>) { |
| 97 | let idx = 0; |
no test coverage detected