| /external/aws-sdk-java-v2/services-custom/s3-transfer-manager/src/main/java/software/amazon/awssdk/transfer/s3/internal/ |
| D | GenericS3TransferManager.java | 121 CompletableFuture<CompletedUpload> returnFuture = new CompletableFuture<>(); in upload() local
161 CompletableFuture<CompletedFileUpload> returnFuture = new CompletableFuture<>(); in uploadFile() local
209 CompletableFuture<CompletedDownload<ResultT>> returnFuture = new CompletableFuture<>(); in download() local
244 CompletableFuture<CompletedFileDownload> returnFuture = new CompletableFuture<>(); in downloadFile() local
253 CompletableFuture<CompletedFileDownload> returnFuture) { in doDownloadFile()
282 CompletableFuture<CompletedFileDownload> returnFuture = new CompletableFuture<>(); in resumeDownloadFile() local
327 private static void handleException(CompletableFuture<CompletedFileDownload> returnFuture, in handleException()
361 CompletableFuture<CompletedCopy> returnFuture = new CompletableFuture<>(); in copy() local
|
| D | AsyncBufferingSubscriber.java | 36 private final CompletableFuture<?> returnFuture; field in AsyncBufferingSubscriber
44 CompletableFuture<Void> returnFuture, in AsyncBufferingSubscriber()
|
| D | DownloadDirectoryHelper.java | 73 CompletableFuture<CompletedDirectoryDownload> returnFuture = new CompletableFuture<>(); in downloadDirectory() local
93 private void doDownloadDirectory(CompletableFuture<CompletedDirectoryDownload> returnFuture, in doDownloadDirectory()
131 CompletableFuture<CompletedDirectoryDownload> returnFuture, in downloadSingleFile()
|
| D | UploadDirectoryHelper.java | 71 CompletableFuture<CompletedDirectoryUpload> returnFuture = new CompletableFuture<>(); in uploadDirectory() local
85 private void doUploadDirectory(CompletableFuture<CompletedDirectoryUpload> returnFuture, in doUploadDirectory()
|
| D | CrtS3TransferManager.java | 76 CompletableFuture<CompletedFileUpload> returnFuture = new CompletableFuture<>(); in uploadFile() local
|
| /external/aws-sdk-java-v2/services/s3/src/main/java/software/amazon/awssdk/services/s3/internal/multipart/ |
| D | UploadWithKnownContentLengthHelper.java | 73 CompletableFuture<PutObjectResponse> returnFuture = new CompletableFuture<>(); in uploadObject() local
92 CompletableFuture<PutObjectResponse> returnFuture) { in uploadInParts()
102 … doUploadInParts(Pair.of(putObjectRequest, asyncRequestBody), contentLength, returnFuture, in uploadInParts() local
110 CompletableFuture<PutObjectResponse> returnFuture, in doUploadInParts()
171 private final CompletableFuture<PutObjectResponse> returnFuture; field in UploadWithKnownContentLengthHelper.KnownContentLengthAsyncRequestBodySubscriber
177 … CompletableFuture<PutObjectResponse> returnFuture) { in KnownContentLengthAsyncRequestBodySubscriber()
|
| D | CopyObjectHelper.java | 65 CompletableFuture<CopyObjectResponse> returnFuture = new CompletableFuture<>(); in copyObject() local
89 … doCopyObject(CopyObjectRequest copyObjectRequest, CompletableFuture<CopyObjectResponse> returnFut… in doCopyObject()
104 CompletableFuture<CopyObjectResponse> returnFuture) { in copyInParts()
125 CompletableFuture<CopyObjectResponse> returnFuture, in doCopyInParts()
232 CompletableFuture<CopyObjectResponse> returnFuture) { in copyInOneChunk()
|
| D | MultipartUploadHelper.java | 67 … CompletableFuture<PutObjectResponse> returnFuture) { in createMultipartUpload()
77 void completeMultipartUpload(CompletableFuture<PutObjectResponse> returnFuture, in completeMultipartUpload()
116 CompletableFuture<PutObjectResponse> returnFuture, in failRequestsElegantly()
141 CompletableFuture<PutObjectResponse> returnFuture) { in uploadInOneChunk()
|
| D | UploadWithUnknownContentLengthHelper.java | 74 CompletableFuture<PutObjectResponse> returnFuture = new CompletableFuture<>(); in uploadObject() local
118 private final CompletableFuture<PutObjectResponse> returnFuture; field in UploadWithUnknownContentLengthHelper.UnknownContentLengthAsyncRequestBodySubscriber
127 … CompletableFuture<PutObjectResponse> returnFuture) { in UnknownContentLengthAsyncRequestBodySubscriber()
|
| D | GenericMultipartHelper.java | 58 public void handleException(CompletableFuture<ResponseT> returnFuture, in handleException()
95 CompletableFuture<ResponseT> returnFuture, in handleExceptionOrResponse()
|
| /external/aws-sdk-java-v2/services/s3/src/main/java/software/amazon/awssdk/services/s3/internal/crossregion/ |
| D | S3CrossRegionAsyncClient.java | 60 CompletableFuture<ReturnT> returnFuture = new CompletableFuture<>(); in invokeOperation() local
76 CompletableFuture<ReturnT> returnFuture) { in redirectToCrossRegionIfRedirectException()
|
| /external/aws-sdk-java-v2/http-clients/netty-nio-client/src/main/java/software/amazon/awssdk/http/nio/netty/internal/ |
| D | ListenerInvokingChannelPool.java | 96 public Future<Channel> acquire(Promise<Channel> returnFuture) { in acquire()
117 public Future<Void> release(Channel channel, Promise<Void> returnFuture) { in release()
|
| /external/aws-sdk-java-v2/core/imds/src/main/java/software/amazon/awssdk/imds/internal/ |
| D | DefaultEc2MetadataAsyncClient.java | 96 CompletableFuture<Ec2MetadataResponse> returnFuture = new CompletableFuture<>(); in get() local
101 …tring path, RetryPolicyContext retryPolicyContext, CompletableFuture<Ec2MetadataResponse> returnFu… in get()
|
| /external/aws-sdk-java-v2/services-custom/s3-transfer-manager/src/test/java/software/amazon/awssdk/transfer/s3/internal/ |
| D | AsyncBufferingSubscriberTest.java | 45 private CompletableFuture<Void> returnFuture; field in AsyncBufferingSubscriberTest
|
| /external/mobile-data-download/javatests/com/google/android/libraries/mobiledatadownload/downloader/offroad/ |
| D | Offroad2FileDownloaderTest.java | 574 ListenableFuture<Void> returnFuture; in checkConnectivity() local
611 ListenableFuture<String> returnFuture; in provideOAuthToken() local
|