Searched refs:opFuture (Results 1 – 1 of 1) sorted by relevance
355 CompletableFuture<Void> opFuture = new CompletableFuture<>(); in waitForAsyncVoid() local356 RemoteCallback callback = new RemoteCallback(result -> setResult(result, opFuture)); in waitForAsyncVoid()358 waitForAsync(asyncCall, callback, opFuture, mOutstandingOps, in waitForAsyncVoid()363 CompletableFuture<T> opFuture, ArrayList<CompletableFuture<T>> outstandingOps, in waitForAsync() argument369 outstandingOps.add(opFuture); in waitForAsync()375 opFuture.completeExceptionally(e); in waitForAsync()378 return opFuture; in waitForAsync()382 outstandingOps.remove(opFuture); in waitForAsync()