@@ -99,7 +99,7 @@ public async Task ProcessPartAsync(
9999 {
100100 if ( partNumber == _partBufferManager . NextExpectedPartNumber )
101101 {
102- await ProcessStreamingPartAsync ( partNumber , response , cancellationToken ) . ConfigureAwait ( false ) ;
102+ ProcessStreamingPart ( partNumber , response ) ;
103103 }
104104 else
105105 {
@@ -113,7 +113,6 @@ public async Task ProcessPartAsync(
113113 /// </summary>
114114 /// <param name="partNumber">The part number being processed.</param>
115115 /// <param name="response">The GetObjectResponse containing the part data. Ownership is transferred to StreamingDataSource.</param>
116- /// <param name="cancellationToken">Cancellation token for the operation.</param>
117116 /// <remarks>
118117 /// This method is called when the part arrives in the expected sequential order, allowing
119118 /// for optimal zero-copy streaming directly to the consumer without buffering into memory.
@@ -129,10 +128,9 @@ public async Task ProcessPartAsync(
129128 /// - If constructor succeeds but AddBufferAsync fails: StreamingDataSource.Dispose() handles the response
130129 /// - If AddBufferAsync succeeds: Buffer manager owns everything and will clean up
131130 /// </remarks>
132- private async Task ProcessStreamingPartAsync (
131+ private void ProcessStreamingPart (
133132 int partNumber ,
134- GetObjectResponse response ,
135- CancellationToken cancellationToken )
133+ GetObjectResponse response )
136134 {
137135 _logger . DebugFormat ( "BufferedPartDataHandler: [Part {0}] Matches NextExpectedPartNumber - streaming directly without buffering" ,
138136 partNumber ) ;
0 commit comments