Home
last modified time | relevance | path

Searched defs:completableFuture (Results 1 – 9 of 9) sorted by relevance

/external/aws-sdk-java-v2/http-clients/aws-crt-client/src/test/java/software/amazon/awssdk/http/crt/internal/
DCrtAsyncRequestExecutorTest.java78 CompletableFuture<HttpClientConnection> completableFuture = new CompletableFuture<>(); in acquireConnectionThrowException_shouldInvokeOnError() local
98 CompletableFuture<HttpClientConnection> completableFuture = new CompletableFuture<>(); in executeAsyncRequest_CrtRuntimeException_shouldInvokeOnError() local
125 CompletableFuture<HttpClientConnection> completableFuture = new CompletableFuture<>(); in cancelRequest_shouldInvokeOnError() local
144 …CompletableFuture<HttpClientConnection> completableFuture = CompletableFutureUtils.failedFuture(ex… in execute_AcquireConnectionFailure_shouldAlwaysWrapIOException() local
156 CompletableFuture<HttpClientConnection> completableFuture = new CompletableFuture<>(); in executeRequest_failedOfIllegalStateException_shouldWrapIOException() local
178 CompletableFuture<HttpClientConnection> completableFuture = new CompletableFuture<>(); in executeRequest_failedOfRetryableHttpException_shouldWrapIOException() local
200 CompletableFuture<HttpClientConnection> completableFuture = new CompletableFuture<>(); in executeRequest_failedOfNonRetryableHttpException_shouldNotWrapIOException() local
DCrtRequestExecutorTest.java76 CompletableFuture<HttpClientConnection> completableFuture = new CompletableFuture<>(); in acquireConnectionThrowException_shouldInvokeOnError() local
90 CompletableFuture<HttpClientConnection> completableFuture = new CompletableFuture<>(); in makeRequestFailed_retryableException_shouldWrapWithIOException() local
106 …CompletableFuture<HttpClientConnection> completableFuture = CompletableFutureUtils.failedFuture(ex… in execute_AcquireConnectionFailure_shouldAlwaysWrapIOException() local
118 CompletableFuture<HttpClientConnection> completableFuture = new CompletableFuture<>(); in executeRequest_failedOfNonRetryableHttpException_shouldNotWrapIOException() local
/external/aws-sdk-java-v2/core/sdk-core/src/main/java/software/amazon/awssdk/core/internal/http/timers/
DAsyncTimeoutTask.java35 private final CompletableFuture<?> completableFuture; field in AsyncTimeoutTask
43 …public AsyncTimeoutTask(CompletableFuture<?> completableFuture, Supplier<SdkClientException> excep… in AsyncTimeoutTask()
DTimerUtils.java46 public static <T> TimeoutTracker timeAsyncTaskIfNeeded(CompletableFuture<T> completableFuture, in timeAsyncTaskIfNeeded()
/external/aws-crt-java/src/main/java/software/amazon/awssdk/crt/eventstream/
DServerConnectionContinuationHandler.java14 private CompletableFuture<Void> completableFuture = new CompletableFuture<>(); field in ServerConnectionContinuationHandler
/external/aws-sdk-java-v2/test/sdk-benchmarks/src/main/java/software/amazon/awssdk/benchmark/utils/
DBenchmarkUtils.java47 CompletableFuture<?> completableFuture, in countDownUponCompletion()
/external/aws-sdk-java-v2/test/stability-tests/src/it/java/software/amazon/awssdk/stability/tests/kinesis/
DKinesisStabilityTest.java180 CompletableFuture<Void> completableFuture = in generateSubscribeToShardFutures() local
/external/aws-sdk-java-v2/utils/src/main/java/software/amazon/awssdk/utils/
DCompletableFutureUtils.java205 CompletableFuture<Void> completableFuture = new CompletableFuture<>(); in anyFail() local
/external/aws-sdk-java-v2/services/s3/src/test/java/software/amazon/awssdk/services/s3/internal/crossregion/
DS3CrossRegionAsyncClientTest.java313 CompletableFuture<ResponseBytes<GetObjectResponse>> completableFuture = in given_CrossRegionClient_when_FutureIsCancelled_then_ShouldCancelTheThread() local