Loading sjrpc/core/rpcconnection.py +6 −0 Original line number Diff line number Diff line Loading @@ -290,6 +290,12 @@ class RpcConnection(object): ThreadedRpcCaller(message, self, func).start() else: RpcCaller(message, self, func).start() else: self.error( message['id'], 'NameError', "remote name '%s' is not defined" % message['method'], ) elif set(RpcConnection.RESPONSE_MESSAGE) <= set(message): # Handle response message from the peer: call = self._calls.get(message['id']) Loading Loading
sjrpc/core/rpcconnection.py +6 −0 Original line number Diff line number Diff line Loading @@ -290,6 +290,12 @@ class RpcConnection(object): ThreadedRpcCaller(message, self, func).start() else: RpcCaller(message, self, func).start() else: self.error( message['id'], 'NameError', "remote name '%s' is not defined" % message['method'], ) elif set(RpcConnection.RESPONSE_MESSAGE) <= set(message): # Handle response message from the peer: call = self._calls.get(message['id']) Loading