

def get_result(self, req_id):
    assert (req_id not in self.waiting_for_result)
    return self.results.pop(req_id)

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