

def call_signal(self, remote_ident, method, params):
    if __debug__:
        self.log.debug(('call_signal ident=%r obj=%r method=%r' % (remote_ident, params['object'], params['method'])))
    self.send_params(remote_ident, params, method.signal_timeout)

dataset/ETHPy150Open dsiroky/snakemq/snakemq/rpc.py RpcClient.call_signal/original