def METHOD_NAME(self):
    futs = []
    for name in self.remote_names:
        futs.append(dist.rpc.rpc_async(name, rpc_reset))
    results = [fut.wait() for fut in futs]
    return np.stack(results)