diff --git a/sdk/src/Services/S3/Custom/Transfer/Internal/BufferedMultipartStream.cs b/sdk/src/Services/S3/Custom/Transfer/Internal/BufferedMultipartStream.cs index 7093c2aa6a7b..655ef366759d 100644 --- a/sdk/src/Services/S3/Custom/Transfer/Internal/BufferedMultipartStream.cs +++ b/sdk/src/Services/S3/Custom/Transfer/Internal/BufferedMultipartStream.cs @@ -39,7 +39,6 @@ internal class BufferedMultipartStream : Stream { private readonly IDownloadManager _downloadCoordinator; private readonly IPartBufferManager _partBufferManager; - private readonly BufferedDownloadConfiguration _config; private bool _initialized = false; private bool _disposed = false; @@ -59,12 +58,10 @@ internal class BufferedMultipartStream : Stream /// /// that coordinates download discovery and orchestration. /// that manages part buffer lifecycle and synchronization. - /// with settings for the stream. - public BufferedMultipartStream(IDownloadManager downloadCoordinator, IPartBufferManager partBufferManager, BufferedDownloadConfiguration config) + public BufferedMultipartStream(IDownloadManager downloadCoordinator, IPartBufferManager partBufferManager) { _downloadCoordinator = downloadCoordinator ?? throw new ArgumentNullException(nameof(downloadCoordinator)); _partBufferManager = partBufferManager ?? throw new ArgumentNullException(nameof(partBufferManager)); - _config = config ?? throw new ArgumentNullException(nameof(config)); } /// @@ -96,7 +93,7 @@ public static BufferedMultipartStream Create(IAmazonS3 s3Client, TransferUtility var dataHandler = new BufferedPartDataHandler(partBufferManager, config); var downloadCoordinator = new MultipartDownloadManager(s3Client, request, config, dataHandler, requestEventHandler); - return new BufferedMultipartStream(downloadCoordinator, partBufferManager, config); + return new BufferedMultipartStream(downloadCoordinator, partBufferManager); } /// diff --git a/sdk/test/Services/S3/UnitTests/Custom/BufferedMultipartStreamTests.cs b/sdk/test/Services/S3/UnitTests/Custom/BufferedMultipartStreamTests.cs index bf0e14a6dda3..a37a7c5055a8 100644 --- a/sdk/test/Services/S3/UnitTests/Custom/BufferedMultipartStreamTests.cs +++ b/sdk/test/Services/S3/UnitTests/Custom/BufferedMultipartStreamTests.cs @@ -53,7 +53,7 @@ public void Setup() private BufferedMultipartStream CreateStream() { - return new BufferedMultipartStream(_mockCoordinator.Object, _mockBufferManager.Object, _config); + return new BufferedMultipartStream(_mockCoordinator.Object, _mockBufferManager.Object); } private async Task CreateInitializedStreamAsync( @@ -99,20 +99,18 @@ public void Constructor_WithValidDependencies_CreatesStream() } [DataTestMethod] - [DataRow(null, "bufferManager", "config", DisplayName = "Null Coordinator")] - [DataRow("coordinator", null, "config", DisplayName = "Null Buffer Manager")] - [DataRow("coordinator", "bufferManager", null, DisplayName = "Null Config")] + [DataRow(null, "bufferManager", DisplayName = "Null Coordinator")] + [DataRow("coordinator", null, DisplayName = "Null Buffer Manager")] [ExpectedException(typeof(ArgumentNullException))] public void Constructor_WithNullParameter_ThrowsArgumentNullException( - string coordinatorKey, string bufferManagerKey, string configKey) + string coordinatorKey, string bufferManagerKey) { // Arrange var coordinator = coordinatorKey != null ? _mockCoordinator.Object : null; var bufferManager = bufferManagerKey != null ? _mockBufferManager.Object : null; - var config = configKey != null ? _config : null; // Act - var stream = new BufferedMultipartStream(coordinator, bufferManager, config); + var stream = new BufferedMultipartStream(coordinator, bufferManager); } #endregion @@ -173,8 +171,7 @@ public async Task InitializeAsync_SinglePart_UsesSinglePartHandler() .ReturnsAsync(discoveryResult); var mockBufferManager = new Mock(); - var config = MultipartDownloadTestHelpers.CreateBufferedDownloadConfiguration(); - var stream = new BufferedMultipartStream(mockCoordinator.Object, mockBufferManager.Object, config); + var stream = new BufferedMultipartStream(mockCoordinator.Object, mockBufferManager.Object); // Act await stream.InitializeAsync(CancellationToken.None); @@ -203,8 +200,7 @@ public async Task InitializeAsync_SinglePart_CallsStartDownloads() .Returns(Task.CompletedTask); var mockBufferManager = new Mock(); - var config = MultipartDownloadTestHelpers.CreateBufferedDownloadConfiguration(); - var stream = new BufferedMultipartStream(mockCoordinator.Object, mockBufferManager.Object, config); + var stream = new BufferedMultipartStream(mockCoordinator.Object, mockBufferManager.Object); // Act await stream.InitializeAsync(CancellationToken.None); @@ -237,8 +233,7 @@ public async Task InitializeAsync_Multipart_UsesMultipartHandler() .Returns(Task.CompletedTask); var mockBufferManager = new Mock(); - var config = MultipartDownloadTestHelpers.CreateBufferedDownloadConfiguration(); - var stream = new BufferedMultipartStream(mockCoordinator.Object, mockBufferManager.Object, config); + var stream = new BufferedMultipartStream(mockCoordinator.Object, mockBufferManager.Object); // Act await stream.InitializeAsync(CancellationToken.None); @@ -265,8 +260,7 @@ public async Task InitializeAsync_Multipart_StartsDownloads() .Returns(Task.CompletedTask); var mockBufferManager = new Mock(); - var config = MultipartDownloadTestHelpers.CreateBufferedDownloadConfiguration(); - var stream = new BufferedMultipartStream(mockCoordinator.Object, mockBufferManager.Object, config); + var stream = new BufferedMultipartStream(mockCoordinator.Object, mockBufferManager.Object); // Act await stream.InitializeAsync(CancellationToken.None); @@ -297,8 +291,7 @@ public async Task InitializeAsync_SetsDiscoveryResult() .ReturnsAsync(discoveryResult); var mockBufferManager = new Mock(); - var config = MultipartDownloadTestHelpers.CreateBufferedDownloadConfiguration(); - var stream = new BufferedMultipartStream(mockCoordinator.Object, mockBufferManager.Object, config); + var stream = new BufferedMultipartStream(mockCoordinator.Object, mockBufferManager.Object); // Act await stream.InitializeAsync(CancellationToken.None); @@ -326,8 +319,7 @@ public async Task InitializeAsync_CalledTwice_ThrowsInvalidOperationException() .ReturnsAsync(discoveryResult); var mockBufferManager = new Mock(); - var config = MultipartDownloadTestHelpers.CreateBufferedDownloadConfiguration(); - var stream = new BufferedMultipartStream(mockCoordinator.Object, mockBufferManager.Object, config); + var stream = new BufferedMultipartStream(mockCoordinator.Object, mockBufferManager.Object); // Act await stream.InitializeAsync(CancellationToken.None); @@ -345,8 +337,7 @@ public async Task ReadAsync_BeforeInitialize_ThrowsInvalidOperationException() // Arrange var mockCoordinator = new Mock(); var mockBufferManager = new Mock(); - var config = MultipartDownloadTestHelpers.CreateBufferedDownloadConfiguration(); - var stream = new BufferedMultipartStream(mockCoordinator.Object, mockBufferManager.Object, config); + var stream = new BufferedMultipartStream(mockCoordinator.Object, mockBufferManager.Object); var buffer = new byte[1024]; @@ -361,8 +352,7 @@ public async Task ReadAsync_AfterDispose_ThrowsObjectDisposedException() // Arrange var mockCoordinator = new Mock(); var mockBufferManager = new Mock(); - var config = MultipartDownloadTestHelpers.CreateBufferedDownloadConfiguration(); - var stream = new BufferedMultipartStream(mockCoordinator.Object, mockBufferManager.Object, config); + var stream = new BufferedMultipartStream(mockCoordinator.Object, mockBufferManager.Object); stream.Dispose(); var buffer = new byte[1024];