| /external/aws-sdk-java-v2/core/sdk-core/src/test/java/software/amazon/awssdk/core/internal/async/ |
| D | FileAsyncRequestBodyTest.java | 76 AsyncRequestBody asyncRequestBody = FileAsyncRequestBody.builder() in readFully_doesNotRequestPastEndOfFile_receivesComplete() local
117 AsyncRequestBody asyncRequestBody = FileAsyncRequestBody.builder() in changingFile_fileGetsShorterThanAlreadyRead_failsBecauseTooShort() local
140 AsyncRequestBody asyncRequestBody = FileAsyncRequestBody.builder() in changingFile_fileGetsShorterThanExistingLength_failsBecauseTooShort() local
166 AsyncRequestBody asyncRequestBody = FileAsyncRequestBody.builder() in changingFile_fileGetsLongerThanExistingLength_failsBecauseTooLong() local
192 AsyncRequestBody asyncRequestBody = FileAsyncRequestBody.builder() in changingFile_fileGetsTouched_failsBecauseUpdatedModificationTime() local
216 AsyncRequestBody asyncRequestBody = FileAsyncRequestBody.builder() in changingFile_fileGetsDeleted_failsBecauseDeleted() local
241 AsyncRequestBody asyncRequestBody = FileAsyncRequestBody.builder() in positionNotZero_shouldReadFromPosition() local
268 AsyncRequestBody asyncRequestBody = FileAsyncRequestBody.builder() in bothPositionAndNumBytesToReadConfigured_shouldHonor() local
294 AsyncRequestBody asyncRequestBody = FileAsyncRequestBody.builder() in numBytesToReadConfigured_shouldHonor() local
|
| D | InputStreamWithExecutorAsyncRequestBodyTest.java | 42 InputStreamWithExecutorAsyncRequestBody asyncRequestBody = in dataFromInputStreamIsCopied() local
80 InputStreamWithExecutorAsyncRequestBody asyncRequestBody = in errorsReadingInputStreamAreForwardedToSubscriber() local
|
| D | SplittingPublisherTest.java | 104 TestAsyncRequestBody asyncRequestBody = new TestAsyncRequestBody() { in contentLengthNotPresent_shouldHandle() local
150 …private static void verifySplitContent(AsyncRequestBody asyncRequestBody, int chunkSize) throws Ex… in verifySplitContent()
|
| /external/aws-sdk-java-v2/core/sdk-core/src/main/java/software/amazon/awssdk/core/runtime/transform/ |
| D | AsyncStreamingRequestMarshaller.java | 34 private final AsyncRequestBody asyncRequestBody; field in AsyncStreamingRequestMarshaller
63 private AsyncRequestBody asyncRequestBody; field in AsyncStreamingRequestMarshaller.Builder
69 public Builder asyncRequestBody(AsyncRequestBody asyncRequestBody) { in asyncRequestBody() method in AsyncStreamingRequestMarshaller.Builder
|
| /external/aws-sdk-java-v2/core/sdk-core/src/test/java/software/amazon/awssdk/core/async/ |
| D | AsyncRequestBodyTest.java | 66 void hasCorrectLength(AsyncRequestBody asyncRequestBody) { in hasCorrectLength()
73 void hasCorrectContent(AsyncRequestBody asyncRequestBody) throws InterruptedException { in hasCorrectContent()
112 AsyncRequestBody asyncRequestBody = AsyncRequestBody.fromBytes(bytes); in fromBytesCopiesTheProvidedByteArray() local
131 AsyncRequestBody asyncRequestBody = AsyncRequestBody.fromBytesUnsafe(bytes); in fromBytesUnsafeDoesNotCopyTheProvidedByteArray() local
152 AsyncRequestBody asyncRequestBody = bodyBuilder.apply(ByteBuffer.wrap(bytes)); in safeByteBufferBuildersCopyTheProvidedBuffer() local
180 AsyncRequestBody asyncRequestBody = bodyBuilder.apply(ByteBuffer.wrap(bytes)); in unsafeByteBufferBuildersDoNotCopyTheProvidedBuffer() local
212 AsyncRequestBody asyncRequestBody = bodyBuilder.apply(bb); in nonRewindingByteBufferBuildersReadFromTheInputBufferPosition() local
244 AsyncRequestBody asyncRequestBody = bodyBuilder.apply(bb); in safeNonRewindingByteBufferBuildersCopyFromTheInputBufferPosition() local
272 AsyncRequestBody asyncRequestBody = bodyBuilder.apply(bb); in rewindingByteBufferBuildersDoNotRewindTheInputBuffer() local
290 AsyncRequestBody asyncRequestBody = bodyBuilder.apply(bb); in rewindingByteBufferBuildersReadTheInputBufferFromTheBeginning() local
|
| /external/aws-sdk-java-v2/core/sdk-core/src/main/java/software/amazon/awssdk/core/internal/async/ |
| D | CompressionAsyncRequestBody.java | 101 Builder asyncRequestBody(AsyncRequestBody asyncRequestBody); in asyncRequestBody() method
120 private AsyncRequestBody asyncRequestBody; field in CompressionAsyncRequestBody.DefaultBuilder
130 public Builder asyncRequestBody(AsyncRequestBody asyncRequestBody) { in asyncRequestBody() argument
|
| D | ChecksumCalculatingAsyncRequestBody.java | 83 … ChecksumCalculatingAsyncRequestBody.Builder asyncRequestBody(AsyncRequestBody asyncRequestBody); in asyncRequestBody() method
104 private AsyncRequestBody asyncRequestBody; field in ChecksumCalculatingAsyncRequestBody.DefaultBuilder
115 public Builder asyncRequestBody(AsyncRequestBody asyncRequestBody) { in asyncRequestBody() argument
|
| D | FileAsyncRequestBodySplitHelper.java | 58 public FileAsyncRequestBodySplitHelper(FileAsyncRequestBody asyncRequestBody, in FileAsyncRequestBodySplitHelper()
62 …Validate.isTrue(asyncRequestBody.contentLength().isPresent(), "Content length must be present", as… in FileAsyncRequestBodySplitHelper() local
|
| D | InputStreamWithExecutorAsyncRequestBody.java | 105 private void doBlockingWrite(BlockingInputStreamAsyncRequestBody asyncRequestBody) { in doBlockingWrite()
|
| /external/aws-sdk-java-v2/services/s3/src/test/java/software/amazon/awssdk/services/s3/internal/multipart/ |
| D | UploadObjectHelperTest.java | 94 public static Stream<AsyncRequestBody> asyncRequestBody() { in asyncRequestBody() method in UploadObjectHelperTest
114 AsyncRequestBody asyncRequestBody = Mockito.mock(AsyncRequestBody.class); in uploadObject_contentLengthDoesNotExceedThresholdAndPartSize_shouldUploadInOneChunk() local
127 AsyncRequestBody asyncRequestBody = in uploadObject_unKnownContentLengthDoesNotExceedPartSize_shouldUploadInOneChunk() local
140 …oadObject_contentLengthExceedThresholdAndPartSize_shouldUseMPU(AsyncRequestBody asyncRequestBody) { in uploadObject_contentLengthExceedThresholdAndPartSize_shouldUseMPU()
178 void mpu_onePartFailed_shouldFailOtherPartsAndAbort(AsyncRequestBody asyncRequestBody) { in mpu_onePartFailed_shouldFailOtherPartsAndAbort()
267 void uploadObject_createMultipartUploadFailed_shouldFail(AsyncRequestBody asyncRequestBody) { in uploadObject_createMultipartUploadFailed_shouldFail()
286 … void uploadObject_completeMultipartFailed_shouldFailAndAbort(AsyncRequestBody asyncRequestBody) { in uploadObject_completeMultipartFailed_shouldFailAndAbort()
|
| /external/aws-sdk-java-v2/core/sdk-core/src/main/java/software/amazon/awssdk/core/interceptor/ |
| D | InterceptorContext.java | 49 private final Optional<AsyncRequestBody> asyncRequestBody; field in InterceptorContext
83 public Optional<AsyncRequestBody> asyncRequestBody() { in asyncRequestBody() method in InterceptorContext
121 private Optional<AsyncRequestBody> asyncRequestBody = Optional.empty(); field in InterceptorContext.Builder
169 public Builder asyncRequestBody(AsyncRequestBody asyncRequestBody) { in asyncRequestBody() argument
|
| D | Context.java | 90 Optional<AsyncRequestBody> asyncRequestBody(); in asyncRequestBody() method
|
| /external/aws-sdk-java-v2/core/auth/src/main/java/software/amazon/awssdk/auth/signer/internal/ |
| D | BaseAsyncAws4Signer.java | 44 …syncRequestBody signAsyncRequestBody(SdkHttpFullRequest request, AsyncRequestBody asyncRequestBody, in signAsyncRequestBody()
57 …ted final AsyncRequestBody signAsync(SdkHttpFullRequest request, AsyncRequestBody asyncRequestBody, in signAsync()
71 AsyncRequestBody asyncRequestBody); in transformRequestProvider()
|
| /external/aws-sdk-java-v2/services/s3/src/main/java/software/amazon/awssdk/services/s3/internal/multipart/ |
| D | UploadWithUnknownContentLengthHelper.java | 73 AsyncRequestBody asyncRequestBody) { in uploadObject()
151 public void onNext(AsyncRequestBody asyncRequestBody) { in onNext()
194 private void sendUploadPartRequest(String uploadId, AsyncRequestBody asyncRequestBody) { in sendUploadPartRequest()
211 … private Pair<UploadPartRequest, AsyncRequestBody> uploadPart(AsyncRequestBody asyncRequestBody) { in uploadPart()
|
| D | UploadWithKnownContentLengthHelper.java | 71 AsyncRequestBody asyncRequestBody, in uploadObject()
91 …adInParts(PutObjectRequest putObjectRequest, long contentLength, AsyncRequestBody asyncRequestBody, in uploadInParts()
207 public void onNext(AsyncRequestBody asyncRequestBody) { in onNext()
|
| D | UploadObjectHelper.java | 62 AsyncRequestBody asyncRequestBody) { in uploadObject()
|
| /external/aws-sdk-java-v2/services/s3/src/test/java/software/amazon/awssdk/services/s3/internal/handlers/ |
| D | AsyncChecksumValidationInterceptorTest.java | 69 …Optional<AsyncRequestBody> asyncRequestBody = interceptor.modifyAsyncHttpContent(modifyHttpRequest, in modifyAsyncHttpContent_putObjectRequestChecksumEnabled_shouldWrapChecksumRequestBody() local
82 …Optional<AsyncRequestBody> asyncRequestBody = interceptor.modifyAsyncHttpContent(modifyHttpRequest, in modifyAsyncHttpContent_nonPutObjectRequest_shouldNotModify() local
94 …Optional<AsyncRequestBody> asyncRequestBody = interceptor.modifyAsyncHttpContent(modifyHttpRequest, in modifyAsyncHttpContent_putObjectRequest_checksumDisabled_shouldNotModify() local
|
| /external/aws-sdk-java-v2/core/sdk-core/src/main/java/software/amazon/awssdk/core/signer/ |
| D | AsyncRequestBodySigner.java | 38 …syncRequestBody signAsyncRequestBody(SdkHttpFullRequest request, AsyncRequestBody asyncRequestBody, in signAsyncRequestBody()
|
| /external/aws-sdk-java-v2/services/s3/src/main/java/software/amazon/awssdk/services/s3/internal/crt/ |
| D | CrtContentLengthOnlyAsyncFileRequestBody.java | 28 private final AsyncRequestBody asyncRequestBody; field in CrtContentLengthOnlyAsyncFileRequestBody
|
| /external/aws-sdk-java-v2/core/sdk-core/src/main/java/software/amazon/awssdk/core/client/handler/ |
| D | ClientExecutionParams.java | 47 private AsyncRequestBody asyncRequestBody; field in ClientExecutionParams
131 …ic ClientExecutionParams<InputT, OutputT> withAsyncRequestBody(AsyncRequestBody asyncRequestBody) { in withAsyncRequestBody()
|
| /external/aws-sdk-java-v2/services/s3/src/test/java/software/amazon/awssdk/services/s3/utils/ |
| D | InterceptorTestUtils.java | 94 public Optional<AsyncRequestBody> asyncRequestBody() { in modifyHttpResponse() method in InterceptorTestUtils
|
| /external/aws-sdk-java-v2/core/aws-core/src/main/java/software/amazon/awssdk/awscore/eventstream/ |
| D | EventStreamInitialRequestInterceptor.java | 85 Publisher<ByteBuffer> asyncRequestBody = context.asyncRequestBody() in modifyAsyncHttpContent() local
|
| /external/aws-sdk-java-v2/services/s3control/src/test/java/software/amazon/awssdk/services/s3control/internal/interceptors/ |
| D | PayloadSigningInterceptorTest.java | 95 public Optional<AsyncRequestBody> asyncRequestBody() { in asyncRequestBody() method in PayloadSigningInterceptorTest.Context
|
| /external/aws-sdk-java-v2/core/sdk-core/src/main/java/software/amazon/awssdk/core/internal/http/pipeline/stages/ |
| D | MakeAsyncHttpRequestStage.java | 266 private final AsyncRequestBody asyncRequestBody; field in MakeAsyncHttpRequestStage.SdkHttpContentPublisherAdapter
268 private SdkHttpContentPublisherAdapter(AsyncRequestBody asyncRequestBody) { in SdkHttpContentPublisherAdapter()
|
| /external/aws-sdk-java-v2/services/mediastoredata/src/it/java/software/amazon/awssdk/services/mediastoredata/ |
| D | RequestCompressionStreamingIntegrationTest.java | 135 …AsyncRequestBody asyncRequestBody = customAsyncRequestBodyWithoutContentLength(UNCOMPRESSED_BODY.g… in putObject_withAsyncStreamingRequestCompression_compressesPayloadAndSendsCorrectly() local
|