

def store_result(self, result):
    req_id = result['req_id']
    try:
        self.waiting_for_result.remove(req_id)
    except KeyError:
        pass
    else:
        self.results[req_id] = req_id

dataset/ETHPy150Open dsiroky/snakemq/snakemq/rpc.py RpcClient.store_result/VarMisuse@52/71 `result`->`req_id`