uploadwithresponse api

GarrettBeatty · GarrettBeatty · commit 21a5f4f6b45a · 2025-10-18T11:42:43.000-04:00
stack-info: PR: #4062, branch: GarrettBeatty/stacked/4
diff --git a/generator/.DevConfigs/77d980ad-8f58-4f2e-97f8-d2c8c5ba3732.json b/generator/.DevConfigs/77d980ad-8f58-4f2e-97f8-d2c8c5ba3732.json
@@ -0,0 +1,12 @@
+{
+  "services": [
+    {
+      "serviceName": "S3",
+      "type": "minor",
+      "changeLogMessages": [
+        "Added UploadWithResponseAsync methods to TransferUtility that return TransferUtilityUploadResponse with upload metadata",
+        "Enhanced upload commands to return response objects with ETag, encryption details, and version information"
+      ]
+    }
+  ]
+}
diff --git a/sdk/src/Services/S3/Custom/Transfer/Internal/AbortMultipartUploadsCommand.cs b/sdk/src/Services/S3/Custom/Transfer/Internal/AbortMultipartUploadsCommand.cs
@@ -28,7 +28,7 @@
 
 namespace Amazon.S3.Transfer.Internal
 {
-    internal partial class AbortMultipartUploadsCommand : BaseCommand
+    internal partial class AbortMultipartUploadsCommand : BaseCommand<TransferUtilityAbortMultipartUploadsResponse>
     {
         IAmazonS3 _s3Client;
         string _bucketName; 
diff --git a/sdk/src/Services/S3/Custom/Transfer/Internal/BaseCommand.cs b/sdk/src/Services/S3/Custom/Transfer/Internal/BaseCommand.cs
@@ -30,13 +30,12 @@
 
 namespace Amazon.S3.Transfer.Internal
 {
-    internal abstract partial class BaseCommand
+    /// <summary>
+    /// Generic base command that returns a typed response
+    /// </summary>
+    /// <typeparam name="TResponse">Type of response returned by the command</typeparam>
+    internal abstract partial class BaseCommand<TResponse> where TResponse : class
     {
-        public virtual object Return
-        {
-            get { return null; }
-        }
-
         protected GetObjectRequest ConvertToGetObjectRequest(BaseDownloadRequest request)
         {
             GetObjectRequest getRequest = new GetObjectRequest()
diff --git a/sdk/src/Services/S3/Custom/Transfer/Internal/DownloadCommand.cs b/sdk/src/Services/S3/Custom/Transfer/Internal/DownloadCommand.cs
@@ -33,7 +33,7 @@
 
 namespace Amazon.S3.Transfer.Internal
 {
-    internal partial class DownloadCommand : BaseCommand
+    internal partial class DownloadCommand : BaseCommand<TransferUtilityDownloadResponse>
     {
         static int MAX_BACKOFF_IN_MILLISECONDS = (int)TimeSpan.FromSeconds(30).TotalMilliseconds;
 
@@ -176,4 +176,3 @@ static ByteRange ByteRangeRemainingForDownload(string filepath)
         }
     }
 }
-
diff --git a/sdk/src/Services/S3/Custom/Transfer/Internal/DownloadDirectoryCommand.cs b/sdk/src/Services/S3/Custom/Transfer/Internal/DownloadDirectoryCommand.cs
@@ -33,7 +33,7 @@
 
 namespace Amazon.S3.Transfer.Internal
 {
-    internal partial class DownloadDirectoryCommand : BaseCommand
+    internal partial class DownloadDirectoryCommand : BaseCommand<TransferUtilityDownloadDirectoryResponse>
     {
         private readonly IAmazonS3 _s3Client;
         private readonly TransferUtilityDownloadDirectoryRequest _request;
diff --git a/sdk/src/Services/S3/Custom/Transfer/Internal/MultipartUploadCommand.cs b/sdk/src/Services/S3/Custom/Transfer/Internal/MultipartUploadCommand.cs
@@ -37,7 +37,7 @@ namespace Amazon.S3.Transfer.Internal
     /// <summary>
     /// The command to manage an upload using the S3 multipart API.
     /// </summary>
-    internal partial class MultipartUploadCommand : BaseCommand
+    internal partial class MultipartUploadCommand : BaseCommand<TransferUtilityUploadResponse>
     {
         IAmazonS3 _s3Client;
         long _partSize;
diff --git a/sdk/src/Services/S3/Custom/Transfer/Internal/OpenStreamCommand.cs b/sdk/src/Services/S3/Custom/Transfer/Internal/OpenStreamCommand.cs
@@ -29,7 +29,7 @@
 
 namespace Amazon.S3.Transfer.Internal
 {
-    internal partial class OpenStreamCommand : BaseCommand
+    internal partial class OpenStreamCommand : BaseCommand<TransferUtilityOpenStreamResponse>
     {
         IAmazonS3 _s3Client;
         TransferUtilityOpenStreamRequest _request;
@@ -59,10 +59,5 @@ internal Stream ResponseStream
         {
             get { return this._responseStream; }
         }
-
-        public override object  Return
-        {
-            get { return this.ResponseStream; }
-        }
     }
 }
diff --git a/sdk/src/Services/S3/Custom/Transfer/Internal/SimpleUploadCommand.cs b/sdk/src/Services/S3/Custom/Transfer/Internal/SimpleUploadCommand.cs
@@ -36,7 +36,7 @@ namespace Amazon.S3.Transfer.Internal
     /// <summary>
     /// This command is for doing regular PutObject requests.
     /// </summary>
-    internal partial class SimpleUploadCommand : BaseCommand
+    internal partial class SimpleUploadCommand : BaseCommand<TransferUtilityUploadResponse>
     {
         IAmazonS3 _s3Client;
         TransferUtilityConfig _config;
diff --git a/sdk/src/Services/S3/Custom/Transfer/Internal/UploadDirectoryCommand.cs b/sdk/src/Services/S3/Custom/Transfer/Internal/UploadDirectoryCommand.cs
@@ -32,7 +32,7 @@ namespace Amazon.S3.Transfer.Internal
     /// This command files all the files that meets the criteria specified in the TransferUtilityUploadDirectoryRequest request
     /// and uploads them.
     /// </summary>
-    internal partial class UploadDirectoryCommand : BaseCommand
+    internal partial class UploadDirectoryCommand : BaseCommand<TransferUtilityUploadDirectoryResponse>
     {
         TransferUtilityUploadDirectoryRequest _request;
         TransferUtility _utility;
diff --git a/sdk/src/Services/S3/Custom/Transfer/Internal/_async/AbortMultipartUploadsCommand.async.cs b/sdk/src/Services/S3/Custom/Transfer/Internal/_async/AbortMultipartUploadsCommand.async.cs
@@ -24,7 +24,7 @@
 
 namespace Amazon.S3.Transfer.Internal
 {
-    internal partial class AbortMultipartUploadsCommand : BaseCommand
+    internal partial class AbortMultipartUploadsCommand : BaseCommand<TransferUtilityAbortMultipartUploadsResponse>
     {
         TransferUtilityConfig _config;
 
@@ -36,7 +36,7 @@ internal AbortMultipartUploadsCommand(IAmazonS3 s3Client, string bucketName, Dat
             this._config = config;
         }
 
-        public override async Task ExecuteAsync(CancellationToken cancellationToken)
+        public override async Task<TransferUtilityAbortMultipartUploadsResponse> ExecuteAsync(CancellationToken cancellationToken)
         {
             if (string.IsNullOrEmpty(this._bucketName))
             {
@@ -88,6 +88,8 @@ await asyncThrottler.WaitAsync(cancellationToken)
 
                 await WhenAllOrFirstExceptionAsync(pendingTasks,cancellationToken)
                     .ConfigureAwait(continueOnCapturedContext: false);
+
+                return new TransferUtilityAbortMultipartUploadsResponse();
             }
             finally
             {
diff --git a/sdk/src/Services/S3/Custom/Transfer/Internal/_async/BaseCommand.async.cs b/sdk/src/Services/S3/Custom/Transfer/Internal/_async/BaseCommand.async.cs
@@ -24,9 +24,12 @@
 
 namespace Amazon.S3.Transfer.Internal
 {
-    internal abstract partial class BaseCommand
+    internal abstract partial class BaseCommand<TResponse> where TResponse : class
     {
-        public abstract Task ExecuteAsync(CancellationToken cancellationToken);
+        /// <summary>
+        /// Executes the command and returns a typed response
+        /// </summary>
+        public abstract Task<TResponse> ExecuteAsync(CancellationToken cancellationToken);
 
         /// <summary>
         ///  Waits for all of the tasks to complete or till any task fails or is canceled.
@@ -80,7 +83,7 @@ await completedTask
             }
         }
 
-        protected static async Task ExecuteCommandAsync(BaseCommand command, CancellationTokenSource internalCts, SemaphoreSlim throttler)
+        protected static async Task ExecuteCommandAsync<T>(BaseCommand<T> command, CancellationTokenSource internalCts, SemaphoreSlim throttler) where T : class
         {
             try
             {
diff --git a/sdk/src/Services/S3/Custom/Transfer/Internal/_async/DownloadCommand.async.cs b/sdk/src/Services/S3/Custom/Transfer/Internal/_async/DownloadCommand.async.cs
@@ -28,9 +28,9 @@
 
 namespace Amazon.S3.Transfer.Internal
 {
-    internal partial class DownloadCommand : BaseCommand
+    internal partial class DownloadCommand : BaseCommand<TransferUtilityDownloadResponse>
     {
-        public override async Task ExecuteAsync(CancellationToken cancellationToken)
+        public override async Task<TransferUtilityDownloadResponse> ExecuteAsync(CancellationToken cancellationToken)
         {
             ValidateRequest();
             GetObjectRequest getRequest = ConvertToGetObjectRequest(this._request);
@@ -130,6 +130,8 @@ await response.WriteResponseStreamToFileAsync(this._request.FilePath, true, canc
                 }
                 WaitBeforeRetry(retries);
             } while (shouldRetry);
+
+            return new TransferUtilityDownloadResponse();
         }
 
         private static bool HandleExceptionForHttpClient(Exception exception, int retries, int maxRetries)
diff --git a/sdk/src/Services/S3/Custom/Transfer/Internal/_async/MultipartUploadCommand.async.cs b/sdk/src/Services/S3/Custom/Transfer/Internal/_async/MultipartUploadCommand.async.cs
@@ -27,18 +27,18 @@
 
 namespace Amazon.S3.Transfer.Internal
 {
-    internal partial class MultipartUploadCommand : BaseCommand
+    internal partial class MultipartUploadCommand : BaseCommand<TransferUtilityUploadResponse>
     {
         public SemaphoreSlim AsyncThrottler { get; set; }
 
-        public override async Task ExecuteAsync(CancellationToken cancellationToken)
+        public override async Task<TransferUtilityUploadResponse> ExecuteAsync(CancellationToken cancellationToken)
         {
             // Fire transfer initiated event FIRST, before choosing path
             FireTransferInitiatedEvent();
 
             if ( (this._fileTransporterRequest.InputStream != null && !this._fileTransporterRequest.InputStream.CanSeek) || this._fileTransporterRequest.ContentLength == -1)
             {
-                await UploadUnseekableStreamAsync(this._fileTransporterRequest, cancellationToken).ConfigureAwait(false);
+                return await UploadUnseekableStreamAsync(this._fileTransporterRequest, cancellationToken).ConfigureAwait(false);
             }
             else
             {
@@ -119,6 +119,7 @@ await localThrottler.WaitAsync(cancellationToken)
 
                     var mappedResponse = ResponseMapper.MapCompleteMultipartUploadResponse(completeResponse);
                     FireTransferCompletedEvent(mappedResponse);
+                    return mappedResponse;
                 }
                 catch (Exception e)
                 {
@@ -202,7 +203,7 @@ private void AbortMultipartUpload(string uploadId)
                 Logger.InfoFormat("Error attempting to abort multipart for key {0}: {1}", this._fileTransporterRequest.Key, e.Message);
             }
         }
-        private async Task UploadUnseekableStreamAsync(TransferUtilityUploadRequest request, CancellationToken cancellationToken = default(CancellationToken))
+        private async Task<TransferUtilityUploadResponse> UploadUnseekableStreamAsync(TransferUtilityUploadRequest request, CancellationToken cancellationToken = default(CancellationToken))
         {
             cancellationToken.ThrowIfCancellationRequested();
 
@@ -303,6 +304,7 @@ private void AbortMultipartUpload(string uploadId)
 
                     var mappedResponse = ResponseMapper.MapCompleteMultipartUploadResponse(completeResponse);
                     FireTransferCompletedEvent(mappedResponse);
+                    return mappedResponse;
                 }
             }
             catch (Exception ex)
diff --git a/sdk/src/Services/S3/Custom/Transfer/Internal/_async/OpenStreamCommand.async.cs b/sdk/src/Services/S3/Custom/Transfer/Internal/_async/OpenStreamCommand.async.cs
@@ -24,14 +24,16 @@
 
 namespace Amazon.S3.Transfer.Internal
 {
-    internal partial class OpenStreamCommand : BaseCommand
+    internal partial class OpenStreamCommand : BaseCommand<TransferUtilityOpenStreamResponse>
     {
-        public override async Task ExecuteAsync(CancellationToken cancellationToken)
+        public override async Task<TransferUtilityOpenStreamResponse> ExecuteAsync(CancellationToken cancellationToken)
         {
             var getRequest = ConstructRequest();
             var response = await _s3Client.GetObjectAsync(getRequest, cancellationToken)
                 .ConfigureAwait(continueOnCapturedContext: false);
             _responseStream = response.ResponseStream;
+
+            return new TransferUtilityOpenStreamResponse();
         }
     }
 }
diff --git a/sdk/src/Services/S3/Custom/Transfer/Internal/_async/SimpleUploadCommand.async.cs b/sdk/src/Services/S3/Custom/Transfer/Internal/_async/SimpleUploadCommand.async.cs
@@ -24,11 +24,11 @@
 
 namespace Amazon.S3.Transfer.Internal
 {
-    internal partial class SimpleUploadCommand : BaseCommand
+    internal partial class SimpleUploadCommand : BaseCommand<TransferUtilityUploadResponse>
     {
         public SemaphoreSlim AsyncThrottler { get; set; }
 
-        public override async Task ExecuteAsync(CancellationToken cancellationToken)
+        public override async Task<TransferUtilityUploadResponse> ExecuteAsync(CancellationToken cancellationToken)
         {
             try
             {
@@ -47,6 +47,8 @@ await this.AsyncThrottler.WaitAsync(cancellationToken)
                 var mappedResponse = ResponseMapper.MapPutObjectResponse(response);
 
                 FireTransferCompletedEvent(mappedResponse);
+                
+                return mappedResponse;
             }
             catch (Exception)
             {
diff --git a/sdk/src/Services/S3/Custom/Transfer/Internal/_bcl+netstandard/DownloadDirectoryCommand.cs b/sdk/src/Services/S3/Custom/Transfer/Internal/_bcl+netstandard/DownloadDirectoryCommand.cs
@@ -25,7 +25,7 @@
 
 namespace Amazon.S3.Transfer.Internal
 {
-    internal partial class DownloadDirectoryCommand : BaseCommand
+    internal partial class DownloadDirectoryCommand : BaseCommand<TransferUtilityDownloadDirectoryResponse>
     {
 
         TransferUtilityConfig _config;
@@ -38,7 +38,7 @@ internal DownloadDirectoryCommand(IAmazonS3 s3Client, TransferUtilityDownloadDir
             this._config = config;
         }
 
-        public override async Task ExecuteAsync(CancellationToken cancellationToken)
+        public override async Task<TransferUtilityDownloadDirectoryResponse> ExecuteAsync(CancellationToken cancellationToken)
         {
             ValidateRequest();
             EnsureDirectoryExists(new DirectoryInfo(this._request.LocalDirectory));
@@ -112,6 +112,8 @@ await asyncThrottler.WaitAsync(cancellationToken)
                 }
                 await WhenAllOrFirstExceptionAsync(pendingTasks, cancellationToken)
                     .ConfigureAwait(continueOnCapturedContext: false);
+
+                return new TransferUtilityDownloadDirectoryResponse();
             }
             finally
             {
diff --git a/sdk/src/Services/S3/Custom/Transfer/Internal/_bcl+netstandard/UploadDirectoryCommand.cs b/sdk/src/Services/S3/Custom/Transfer/Internal/_bcl+netstandard/UploadDirectoryCommand.cs
@@ -23,11 +23,11 @@
 
 namespace Amazon.S3.Transfer.Internal
 {
-    internal partial class UploadDirectoryCommand : BaseCommand
+    internal partial class UploadDirectoryCommand : BaseCommand<TransferUtilityUploadDirectoryResponse>
     {
         public bool UploadFilesConcurrently { get; set; }
 
-        public override async Task ExecuteAsync(CancellationToken cancellationToken)
+        public override async Task<TransferUtilityUploadDirectoryResponse> ExecuteAsync(CancellationToken cancellationToken)
         {
             string prefix = GetKeyPrefix();
 
@@ -87,6 +87,8 @@ await WhenAllOrFirstExceptionAsync(pendingTasks, cancellationToken)
                 if (asyncThrottler != null)
                     asyncThrottler.Dispose();
             }
+
+            return new TransferUtilityUploadDirectoryResponse();
         }
 
         private Task<string[]> GetFiles(string path, string searchPattern, SearchOption searchOption, CancellationToken cancellationToken)
diff --git a/sdk/src/Services/S3/Custom/Transfer/TransferUtility.cs b/sdk/src/Services/S3/Custom/Transfer/TransferUtility.cs
@@ -386,7 +386,7 @@ private static TransferUtilityUploadRequest ConstructUploadRequest(Stream stream
             };
         }
 
-        internal BaseCommand GetUploadCommand(TransferUtilityUploadRequest request)
+        internal BaseCommand<TransferUtilityUploadResponse> GetUploadCommand(TransferUtilityUploadRequest request)
         {
             validate(request);
 
diff --git a/sdk/src/Services/S3/Custom/Transfer/TransferUtilityAbortMultipartUploadsResponse.cs b/sdk/src/Services/S3/Custom/Transfer/TransferUtilityAbortMultipartUploadsResponse.cs
@@ -0,0 +1,35 @@
+/*******************************************************************************
+ *  Copyright Amazon.com, Inc. or its affiliates. All Rights Reserved.
+ *  Licensed under the Apache License, Version 2.0 (the "License"). You may not use
+ *  this file except in compliance with the License. A copy of the License is located at
+ *
+ *  http://aws.amazon.com/apache2.0
+ *
+ *  or in the "license" file accompanying this file.
+ *  This file is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR
+ *  CONDITIONS OF ANY KIND, either express or implied. See the License for the
+ *  specific language governing permissions and limitations under the License.
+ * *****************************************************************************
+ *    __  _    _  ___
+ *   (  )( \/\/ )/ __)
+ *   /__\ \    / \__ \
+ *  (_)(_) \/\/  (___/
+ *
+ *  AWS SDK for .NET
+ *  API Version: 2006-03-01
+ *
+ */
+
+using Amazon.Runtime;
+
+namespace Amazon.S3.Transfer
+{
+    /// <summary>
+    /// Response object for Transfer Utility abort multipart uploads operations.
+    /// Contains response metadata from abort multipart uploads operations.
+    /// </summary>
+    public class TransferUtilityAbortMultipartUploadsResponse : AmazonWebServiceResponse
+    {
+        // Empty placeholder class - properties will be added in future iterations
+    }
+}
diff --git a/sdk/src/Services/S3/Custom/Transfer/TransferUtilityDownloadDirectoryResponse.cs b/sdk/src/Services/S3/Custom/Transfer/TransferUtilityDownloadDirectoryResponse.cs
@@ -0,0 +1,26 @@
+/*
+ * Copyright Amazon.com, Inc. or its affiliates. All Rights Reserved.
+ * 
+ * Licensed under the Apache License, Version 2.0 (the "License").
+ * You may not use this file except in compliance with the License.
+ * A copy of the License is located at
+ * 
+ *  http://aws.amazon.com/apache2.0
+ * 
+ * or in the "license" file accompanying this file. This file is distributed
+ * on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either
+ * express or implied. See the License for the specific language governing
+ * permissions and limitations under the License.
+ */
+
+using Amazon.Runtime;
+
+namespace Amazon.S3.Model
+{
+    /// <summary>
+    /// Contains the details returned from a Transfer Utility download directory operation.
+    /// </summary>
+    public class TransferUtilityDownloadDirectoryResponse : AmazonWebServiceResponse
+    {
+    }
+}
diff --git a/sdk/src/Services/S3/Custom/Transfer/TransferUtilityDownloadResponse.cs b/sdk/src/Services/S3/Custom/Transfer/TransferUtilityDownloadResponse.cs
diff --git a/sdk/src/Services/S3/Custom/Transfer/TransferUtilityOpenStreamResponse.cs b/sdk/src/Services/S3/Custom/Transfer/TransferUtilityOpenStreamResponse.cs
diff --git a/sdk/src/Services/S3/Custom/Transfer/TransferUtilityUploadDirectoryResponse.cs b/sdk/src/Services/S3/Custom/Transfer/TransferUtilityUploadDirectoryResponse.cs
diff --git a/sdk/src/Services/S3/Custom/Transfer/_async/TransferUtility.async.cs b/sdk/src/Services/S3/Custom/Transfer/_async/TransferUtility.async.cs

Original file line number	Diff line number	Diff line change
`@@ -28,7 +28,7 @@`
`28`	`28`
`29`	`29`	`namespace Amazon.S3.Transfer.Internal`
`30`	`30`	`{`
`31`		`- internal partial class AbortMultipartUploadsCommand : BaseCommand`
	`31`	`+ internal partial class AbortMultipartUploadsCommand : BaseCommand<TransferUtilityAbortMultipartUploadsResponse>`
`32`	`32`	`{`
`33`	`33`	`IAmazonS3 _s3Client;`
`34`	`34`	`string _bucketName;`
Original file line number	Diff line number	Diff line change
`@@ -30,13 +30,12 @@`
`30`	`30`
`31`	`31`	`namespace Amazon.S3.Transfer.Internal`
`32`	`32`	`{`
`33`		`- internal abstract partial class BaseCommand`
	`33`	`+ /// <summary>`
	`34`	`+ /// Generic base command that returns a typed response`
	`35`	`+ /// </summary>`
	`36`	`+ /// <typeparam name="TResponse">Type of response returned by the command</typeparam>`
	`37`	`+ internal abstract partial class BaseCommand<TResponse> where TResponse : class`
`34`	`38`	`{`
`35`		`- public virtual object Return`
`36`		`- {`
`37`		`- get { return null; }`
`38`		`- }`
`39`		`-`
`40`	`39`	`protected GetObjectRequest ConvertToGetObjectRequest(BaseDownloadRequest request)`
`41`	`40`	`{`
`42`	`41`	`GetObjectRequest getRequest = new GetObjectRequest()`
Original file line number	Diff line number	Diff line change
`@@ -33,7 +33,7 @@`
`33`	`33`
`34`	`34`	`namespace Amazon.S3.Transfer.Internal`
`35`	`35`	`{`
`36`		`- internal partial class DownloadCommand : BaseCommand`
	`36`	`+ internal partial class DownloadCommand : BaseCommand<TransferUtilityDownloadResponse>`
`37`	`37`	`{`
`38`	`38`	`static int MAX_BACKOFF_IN_MILLISECONDS = (int)TimeSpan.FromSeconds(30).TotalMilliseconds;`
`39`	`39`
`@@ -176,4 +176,3 @@ static ByteRange ByteRangeRemainingForDownload(string filepath)`
`176`	`176`	`}`
`177`	`177`	`}`
`178`	`178`	`}`
`179`		`-`
Original file line number	Diff line number	Diff line change
`@@ -37,7 +37,7 @@ namespace Amazon.S3.Transfer.Internal`
`37`	`37`	`/// <summary>`
`38`	`38`	`/// The command to manage an upload using the S3 multipart API.`
`39`	`39`	`/// </summary>`
`40`		`- internal partial class MultipartUploadCommand : BaseCommand`
	`40`	`+ internal partial class MultipartUploadCommand : BaseCommand<TransferUtilityUploadResponse>`
`41`	`41`	`{`
`42`	`42`	`IAmazonS3 _s3Client;`
`43`	`43`	`long _partSize;`
Original file line number	Diff line number	Diff line change
`@@ -29,7 +29,7 @@`
`29`	`29`
`30`	`30`	`namespace Amazon.S3.Transfer.Internal`
`31`	`31`	`{`
`32`		`- internal partial class OpenStreamCommand : BaseCommand`
	`32`	`+ internal partial class OpenStreamCommand : BaseCommand<TransferUtilityOpenStreamResponse>`
`33`	`33`	`{`
`34`	`34`	`IAmazonS3 _s3Client;`
`35`	`35`	`TransferUtilityOpenStreamRequest _request;`
`@@ -59,10 +59,5 @@ internal Stream ResponseStream`
`59`	`59`	`{`
`60`	`60`	`get { return this._responseStream; }`
`61`	`61`	`}`
`62`		`-`
`63`		`- public override object Return`
`64`		`- {`
`65`		`- get { return this.ResponseStream; }`
`66`		`- }`
`67`	`62`	`}`
`68`	`63`	`}`
Original file line number	Diff line number	Diff line change
`@@ -36,7 +36,7 @@ namespace Amazon.S3.Transfer.Internal`
`36`	`36`	`/// <summary>`
`37`	`37`	`/// This command is for doing regular PutObject requests.`
`38`	`38`	`/// </summary>`
`39`		`- internal partial class SimpleUploadCommand : BaseCommand`
	`39`	`+ internal partial class SimpleUploadCommand : BaseCommand<TransferUtilityUploadResponse>`
`40`	`40`	`{`
`41`	`41`	`IAmazonS3 _s3Client;`
`42`	`42`	`TransferUtilityConfig _config;`
Original file line number	Diff line number	Diff line change
`@@ -32,7 +32,7 @@ namespace Amazon.S3.Transfer.Internal`
`32`	`32`	`/// This command files all the files that meets the criteria specified in the TransferUtilityUploadDirectoryRequest request`
`33`	`33`	`/// and uploads them.`
`34`	`34`	`/// </summary>`
`35`		`- internal partial class UploadDirectoryCommand : BaseCommand`
	`35`	`+ internal partial class UploadDirectoryCommand : BaseCommand<TransferUtilityUploadDirectoryResponse>`
`36`	`36`	`{`
`37`	`37`	`TransferUtilityUploadDirectoryRequest _request;`
`38`	`38`	`TransferUtility _utility;`
Original file line number	Diff line number	Diff line change
`@@ -24,7 +24,7 @@`
`24`	`24`
`25`	`25`	`namespace Amazon.S3.Transfer.Internal`
`26`	`26`	`{`
`27`		`- internal partial class AbortMultipartUploadsCommand : BaseCommand`
	`27`	`+ internal partial class AbortMultipartUploadsCommand : BaseCommand<TransferUtilityAbortMultipartUploadsResponse>`
`28`	`28`	`{`
`29`	`29`	`TransferUtilityConfig _config;`
`30`	`30`
`@@ -36,7 +36,7 @@ internal AbortMultipartUploadsCommand(IAmazonS3 s3Client, string bucketName, Dat`
`36`	`36`	`this._config = config;`
`37`	`37`	`}`
`38`	`38`
`39`		`- public override async Task ExecuteAsync(CancellationToken cancellationToken)`
	`39`	`+ public override async Task<TransferUtilityAbortMultipartUploadsResponse> ExecuteAsync(CancellationToken cancellationToken)`
`40`	`40`	`{`
`41`	`41`	`if (string.IsNullOrEmpty(this._bucketName))`
`42`	`42`	`{`
`@@ -88,6 +88,8 @@ await asyncThrottler.WaitAsync(cancellationToken)`
`88`	`88`
`89`	`89`	`await WhenAllOrFirstExceptionAsync(pendingTasks,cancellationToken)`
`90`	`90`	`.ConfigureAwait(continueOnCapturedContext: false);`
	`91`	`+`
	`92`	`+ return new TransferUtilityAbortMultipartUploadsResponse();`
`91`	`93`	`}`
`92`	`94`	`finally`
`93`	`95`	`{`