Searched refs:migrateFuture (Results 1 – 2 of 2) sorted by relevance
196 CompletableFuture<Void> migrateFuture = new CompletableFuture<>(); in migrate() local197 mControllerService.scheduleMigration(pendingDataset, newOperationReceiver(migrateFuture)); in migrate()198 return waitForFuture(migrateFuture, MIGRATE_TIMEOUT, getErrorWriter()); in migrate()
510 CompletableFuture<Void> migrateFuture = new CompletableFuture<>();515 pendingDataset2, mExecutor, newOutcomeReceiver(migrateFuture));516 migrateFuture.get(CALLBACK_TIMEOUT_MILLIS, MILLISECONDS);555 CompletableFuture<Void> migrateFuture = new CompletableFuture<>();557 mController.scheduleMigration(pendingDataset, mExecutor, newOutcomeReceiver(migrateFuture));561 assertThrows(ExecutionException.class, migrateFuture::get).getCause();