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