(self, command: commands.CallRpcCommand)
Client wishes to call a remote RPC
Client wishes to call a remote RPC
Client wishes to call a remote RPC
async def handle_call_rpc(self, command: commands.CallRpcCommand):
        """Client wishes to call a remote RPC"""
        api_name = command.message.api_name

        rpc_transport = self.transport_registry.get_rpc_transport(api_name)
        result_transport = self.transport_registry.get_result_transport(api_name)

        # TODO: Perhaps move return_path out of RpcMessage, as this feels a little gross
        command.message.return_path = await result_transport.get_return_path(command.message)

        await rpc_transport.call_rpc(command.message, options=command.options)
async def handle_call_rpc ( self , command : commands . CallRpcCommand ) : api_name = command . message . api_name rpc_transport = self . transport_registry . get_rpc_transport ( api_name ) result_transport = self . transport_registry . get_result_transport ( api_name ) # TODO: Perhaps move return_path out of RpcMessage, as this feels a little gross command . message . return_path = await result_transport . get_return_path ( command . message ) await rpc_transport . call_rpc ( command . message , options = command . options )