

def __init__(self, receive_hook, pickler=pickle):
    self.log = logging.getLogger('snakemq.rpc.client')
    self.receive_hook = receive_hook
    self.pickler = pickler
    self.method_proxies = {
        
    }
    self.exception_handler = None
    self.results = {
        
    }
    self.waiting_for_result = set()
    self.lock = threading.Lock()
    self.cond = threading.Condition(self.lock)
    self.connected = {
        
    }
    receive_hook.register(REPLY_PREFIX, self.on_recv)
    receive_hook.messaging.on_connect.add(self.on_connect)
    receive_hook.messaging.on_disconnect.add(self.on_disconnect)

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