

def on_recv(self, dummy_conn_id, dummy_ident, message):
    res = self.pickler.loads(message.data[len(REPLY_PREFIX):])
    if __debug__:
        self.log.debug(('reply req_id=%r' % b2a_hex(res['req_id'])))
    with self.cond:
        self.store_result(res)
        self.cond.notify_all()

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