Home
last modified time | relevance | path

Searched defs:asyncRequestBody (Results 1 – 25 of 35) sorted by relevance

12

/aosp_15_r20/external/aws-sdk-java-v2/core/sdk-core/src/test/java/software/amazon/awssdk/core/internal/async/
H A DFileAsyncRequestBodyTest.java76 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
H A DInputStreamWithExecutorAsyncRequestBodyTest.java42 InputStreamWithExecutorAsyncRequestBody asyncRequestBody = in dataFromInputStreamIsCopied() local
80 InputStreamWithExecutorAsyncRequestBody asyncRequestBody = in errorsReadingInputStreamAreForwardedToSubscriber() local
H A DSplittingPublisherTest.java104 TestAsyncRequestBody asyncRequestBody = new TestAsyncRequestBody() { in contentLengthNotPresent_shouldHandle() local
150 …private static void verifySplitContent(AsyncRequestBody asyncRequestBody, int chunkSize) throws Ex… in verifySplitContent()
/aosp_15_r20/external/aws-sdk-java-v2/core/sdk-core/src/test/java/software/amazon/awssdk/core/async/
H A DAsyncRequestBodyTest.java66 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
/aosp_15_r20/external/aws-sdk-java-v2/services/s3/src/test/java/software/amazon/awssdk/services/s3/internal/multipart/
H A DUploadObjectHelperTest.java94 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()
/aosp_15_r20/external/aws-sdk-java-v2/core/sdk-core/src/main/java/software/amazon/awssdk/core/internal/async/
H A DCompressionAsyncRequestBody.java101 Builder asyncRequestBody(AsyncRequestBody asyncRequestBody); in asyncRequestBody() argument
120 private AsyncRequestBody asyncRequestBody; field in CompressionAsyncRequestBody.DefaultBuilder
130 public Builder asyncRequestBody(AsyncRequestBody asyncRequestBody) { in asyncRequestBody() argument
H A DChecksumCalculatingAsyncRequestBody.java83 … ChecksumCalculatingAsyncRequestBody.Builder asyncRequestBody(AsyncRequestBody asyncRequestBody); in asyncRequestBody() argument
104 private AsyncRequestBody asyncRequestBody; field in ChecksumCalculatingAsyncRequestBody.DefaultBuilder
115 public Builder asyncRequestBody(AsyncRequestBody asyncRequestBody) { in asyncRequestBody() argument
H A DFileAsyncRequestBodySplitHelper.java58 public FileAsyncRequestBodySplitHelper(FileAsyncRequestBody asyncRequestBody, in FileAsyncRequestBodySplitHelper()
62 …Validate.isTrue(asyncRequestBody.contentLength().isPresent(), "Content length must be present", as… in FileAsyncRequestBodySplitHelper() local
H A DInputStreamWithExecutorAsyncRequestBody.java105 private void doBlockingWrite(BlockingInputStreamAsyncRequestBody asyncRequestBody) { in doBlockingWrite()
/aosp_15_r20/external/aws-sdk-java-v2/core/sdk-core/src/main/java/software/amazon/awssdk/core/interceptor/
H A DInterceptorContext.java49 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() method in InterceptorContext.Builder
/aosp_15_r20/external/aws-sdk-java-v2/core/sdk-core/src/main/java/software/amazon/awssdk/core/runtime/transform/
H A DAsyncStreamingRequestMarshaller.java34 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
/aosp_15_r20/external/aws-sdk-java-v2/services/s3/src/main/java/software/amazon/awssdk/services/s3/internal/multipart/
H A DUploadWithUnknownContentLengthHelper.java73 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()
H A DUploadWithKnownContentLengthHelper.java71 AsyncRequestBody asyncRequestBody, in uploadObject()
91 …adInParts(PutObjectRequest putObjectRequest, long contentLength, AsyncRequestBody asyncRequestBody, in uploadInParts()
207 public void onNext(AsyncRequestBody asyncRequestBody) { in onNext()
H A DUploadObjectHelper.java62 AsyncRequestBody asyncRequestBody) { in uploadObject()
/aosp_15_r20/external/aws-sdk-java-v2/core/auth/src/main/java/software/amazon/awssdk/auth/signer/internal/
H A DBaseAsyncAws4Signer.java44 …syncRequestBody signAsyncRequestBody(SdkHttpFullRequest request, AsyncRequestBody asyncRequestBody, in signAsyncRequestBody()
57 …ted final AsyncRequestBody signAsync(SdkHttpFullRequest request, AsyncRequestBody asyncRequestBody, in signAsync()
71 AsyncRequestBody asyncRequestBody); in transformRequestProvider()
/aosp_15_r20/external/aws-sdk-java-v2/services/s3/src/test/java/software/amazon/awssdk/services/s3/internal/handlers/
H A DAsyncChecksumValidationInterceptorTest.java69 …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
/aosp_15_r20/external/aws-sdk-java-v2/core/sdk-core/src/main/java/software/amazon/awssdk/core/client/handler/
H A DClientExecutionParams.java47 private AsyncRequestBody asyncRequestBody; field in ClientExecutionParams
131 …ic ClientExecutionParams<InputT, OutputT> withAsyncRequestBody(AsyncRequestBody asyncRequestBody) { in withAsyncRequestBody()
/aosp_15_r20/external/aws-sdk-java-v2/core/sdk-core/src/main/java/software/amazon/awssdk/core/internal/http/pipeline/stages/
H A DMakeAsyncHttpRequestStage.java266 private final AsyncRequestBody asyncRequestBody; field in MakeAsyncHttpRequestStage.SdkHttpContentPublisherAdapter
268 private SdkHttpContentPublisherAdapter(AsyncRequestBody asyncRequestBody) { in SdkHttpContentPublisherAdapter()
/aosp_15_r20/external/aws-sdk-java-v2/codegen/src/main/java/software/amazon/awssdk/codegen/poet/client/specs/
H A DJsonProtocolSpec.java221 String asyncRequestBody = opModel.hasStreamingInput() ? ".withAsyncRequestBody(requestBody)" in asyncExecutionHandler() local
321 private CodeBlock asyncRequestBody(OperationModel opModel) { in asyncRequestBody() method in JsonProtocolSpec
/aosp_15_r20/external/aws-sdk-java-v2/core/sdk-core/src/main/java/software/amazon/awssdk/core/signer/
H A DAsyncRequestBodySigner.java38 …syncRequestBody signAsyncRequestBody(SdkHttpFullRequest request, AsyncRequestBody asyncRequestBody, in signAsyncRequestBody()
/aosp_15_r20/external/aws-sdk-java-v2/services/s3/src/main/java/software/amazon/awssdk/services/s3/internal/crt/
H A DCrtContentLengthOnlyAsyncFileRequestBody.java28 private final AsyncRequestBody asyncRequestBody; field in CrtContentLengthOnlyAsyncFileRequestBody
/aosp_15_r20/external/aws-sdk-java-v2/services/s3/src/test/java/software/amazon/awssdk/services/s3/utils/
H A DInterceptorTestUtils.java94 public Optional<AsyncRequestBody> asyncRequestBody() { in modifyHttpResponse() method in InterceptorTestUtils
/aosp_15_r20/external/aws-sdk-java-v2/core/aws-core/src/main/java/software/amazon/awssdk/awscore/eventstream/
H A DEventStreamInitialRequestInterceptor.java85 Publisher<ByteBuffer> asyncRequestBody = context.asyncRequestBody() in modifyAsyncHttpContent() local
/aosp_15_r20/external/aws-sdk-java-v2/services/s3control/src/test/java/software/amazon/awssdk/services/s3control/internal/interceptors/
H A DPayloadSigningInterceptorTest.java95 public Optional<AsyncRequestBody> asyncRequestBody() { in asyncRequestBody() method in PayloadSigningInterceptorTest.Context
/aosp_15_r20/external/aws-sdk-java-v2/services/mediastoredata/src/it/java/software/amazon/awssdk/services/mediastoredata/
H A DRequestCompressionStreamingIntegrationTest.java135 …AsyncRequestBody asyncRequestBody = customAsyncRequestBodyWithoutContentLength(UNCOMPRESSED_BODY.g… in putObject_withAsyncStreamingRequestCompression_compressesPayloadAndSendsCorrectly() local

12