Revert "Wrap CrtS3RuntimeException to SdkServiceException"

Author: joviegas

services-custom/s3-transfer-manager/src/main/java/software/amazon/awssdk/transfer/s3/internal/CrtErrorHandler.java

@@ -39,7 +39,6 @@ public class CrtResponseDataConsumerAdapter<ReturnT> implements ResponseDataCons
     private final CompletableFuture<ReturnT> future;
     private final S3CrtDataPublisher publisher;
     private final ResponseHeadersHandler headerHandler;
-    private final CrtErrorHandler errorHandler;
 
     public CrtResponseDataConsumerAdapter(AsyncResponseTransformer<GetObjectResponse, ReturnT> transformer) {
         this(transformer, new S3CrtDataPublisher(), new ResponseHeadersHandler());
@@ -53,7 +52,6 @@ public CrtResponseDataConsumerAdapter(AsyncResponseTransformer<GetObjectResponse
         this.future = transformer.prepare();
         this.publisher = s3CrtDataPublisher;
         this.headerHandler = headersHandler;
-        this.errorHandler = new CrtErrorHandler();
     }
 
     public CompletableFuture<ReturnT> transformerFuture() {
@@ -89,9 +87,8 @@ public void onResponseData(ByteBuffer byteBuffer) {
     @Override
     public void onException(CrtRuntimeException e) {
         log.debug(() -> "An error occurred ", e);
-        Exception transformException = errorHandler.transformException(e);
-        transformer.exceptionOccurred(transformException);
-        publisher.notifyError(transformException);
+        transformer.exceptionOccurred(e);
+        publisher.notifyError(e);
     }
 
     @Override

services-custom/s3-transfer-manager/src/main/java/software/amazon/awssdk/transfer/s3/internal/CrtResponseDataConsumerAdapter.java

@@ -37,7 +37,6 @@
 public final class DefaultS3CrtAsyncClient implements S3CrtAsyncClient {
     private final S3NativeClient s3NativeClient;
     private final S3NativeClientConfiguration configuration;
-    private final CrtErrorHandler crtErrorHandler;
 
     public DefaultS3CrtAsyncClient(DefaultS3CrtClientBuilder builder) {
         S3NativeClientConfiguration.Builder configBuilder =
@@ -59,15 +58,13 @@ public DefaultS3CrtAsyncClient(DefaultS3CrtClientBuilder builder) {
                                                  configuration.partSizeBytes(),
                                                  configuration.targetThroughputInGbps(),
                                                  configuration.maxConcurrency());
-        crtErrorHandler = new CrtErrorHandler();
     }
 
     @SdkTestInternalApi
     DefaultS3CrtAsyncClient(S3NativeClientConfiguration configuration,
                             S3NativeClient nativeClient) {
         this.configuration = configuration;
         this.s3NativeClient = nativeClient;
-        crtErrorHandler = new CrtErrorHandler();
     }
 
     @Override
@@ -99,7 +96,6 @@ public CompletableFuture<PutObjectResponse> putObject(PutObjectRequest putObject
         CompletableFuture<PutObjectResponse> returnFuture = new CompletableFuture<>();
 
         com.amazonaws.s3.model.PutObjectRequest adaptedRequest = S3CrtPojoConversion.toCrtPutObjectRequest(putObjectRequest);
-        CompletableFuture<PutObjectResponse> returnFuture = new CompletableFuture<>();
 
         if (adaptedRequest.contentLength() == null && requestBody.contentLength().isPresent()) {
             adaptedRequest = adaptedRequest.toBuilder()