Loading sjrpc/core/protocols/rpc.py +2 −10 Original line number Diff line number Diff line Loading @@ -379,11 +379,7 @@ class RpcProtocol(Protocol): didnt respond. ''' if '_timeout' in kwargs: timeout = kwargs['_timeout'] del kwargs['_timeout'] else: timeout = self._call_timeout timeout = kwargs.pop('_timeout', self._call_timeout) # Send the call to the peer: msg_id = self._send_call(method_name, *args, **kwargs) Loading Loading @@ -419,11 +415,7 @@ class RpcProtocol(Protocol): ''' # Extract _data from argument: if '_data' in kwargs: data = kwargs['_data'] del kwargs['_data'] else: data = None data = kwargs.pop('_data', None) # Send the call to the peer: msg_id = self._send_call(method_name, *args, **kwargs) # Register the call but don't wait for the response: Loading Loading
sjrpc/core/protocols/rpc.py +2 −10 Original line number Diff line number Diff line Loading @@ -379,11 +379,7 @@ class RpcProtocol(Protocol): didnt respond. ''' if '_timeout' in kwargs: timeout = kwargs['_timeout'] del kwargs['_timeout'] else: timeout = self._call_timeout timeout = kwargs.pop('_timeout', self._call_timeout) # Send the call to the peer: msg_id = self._send_call(method_name, *args, **kwargs) Loading Loading @@ -419,11 +415,7 @@ class RpcProtocol(Protocol): ''' # Extract _data from argument: if '_data' in kwargs: data = kwargs['_data'] del kwargs['_data'] else: data = None data = kwargs.pop('_data', None) # Send the call to the peer: msg_id = self._send_call(method_name, *args, **kwargs) # Register the call but don't wait for the response: Loading