diff --git a/sdk/core/System.ClientModel/src/Pipeline/HttpClientPipelineTransport.Response.cs b/sdk/core/System.ClientModel/src/Pipeline/HttpClientPipelineTransport.Response.cs index 624664592d01..9253e29395aa 100644 --- a/sdk/core/System.ClientModel/src/Pipeline/HttpClientPipelineTransport.Response.cs +++ b/sdk/core/System.ClientModel/src/Pipeline/HttpClientPipelineTransport.Response.cs @@ -53,7 +53,7 @@ public override Stream? ContentStream return _contentStream; } - return ReadContent().ToStream(); + return BufferContent().ToStream(); } set { diff --git a/sdk/core/System.ClientModel/tests/Pipeline/HttpClientPipelineTransportTests.cs b/sdk/core/System.ClientModel/tests/Pipeline/HttpClientPipelineTransportTests.cs index a1ccc42dff94..845569806a28 100644 --- a/sdk/core/System.ClientModel/tests/Pipeline/HttpClientPipelineTransportTests.cs +++ b/sdk/core/System.ClientModel/tests/Pipeline/HttpClientPipelineTransportTests.cs @@ -396,7 +396,7 @@ public async Task ResponseReadContentReturnsContentIfBuffered() await transport.ProcessSyncOrAsync(message, IsAsync); - BinaryData content = await message.Response!.ReadContentSyncOrAsync(default, IsAsync); + BinaryData content = await message.Response!.BufferContentSyncOrAsync(default, IsAsync); Assert.AreEqual(message.Response!.Content, content); } @@ -416,7 +416,7 @@ public async Task ResponseReadContentReturnsEmptyWhenNoResponseContent() await transport.ProcessSyncOrAsync(message, IsAsync); - BinaryData content = await message.Response!.ReadContentSyncOrAsync(default, IsAsync); + BinaryData content = await message.Response!.BufferContentSyncOrAsync(default, IsAsync); Assert.AreEqual(0, content.ToMemory().Length); } @@ -439,7 +439,7 @@ public async Task ResponseReadContentReturnsEmptyWhenContentStreamNull() // Explicitly assign ContentStream via property setter message.Response!.ContentStream = null; - BinaryData content = await message.Response!.ReadContentSyncOrAsync(default, IsAsync); + BinaryData content = await message.Response!.BufferContentSyncOrAsync(default, IsAsync); Assert.AreEqual(0, content.ToMemory().Length); } @@ -467,7 +467,7 @@ public async Task ResponseReadContentThrowsWhenPositionNonZero() message.Response!.ContentStream!.ReadByte(); - Assert.ThrowsAsync(async() => { await message.Response!.ReadContentSyncOrAsync(default, IsAsync); }); + Assert.ThrowsAsync(async() => { await message.Response!.BufferContentSyncOrAsync(default, IsAsync); }); } [Test] diff --git a/sdk/core/System.ClientModel/tests/TestFramework/Mocks/MockSyncAsyncExtensions.cs b/sdk/core/System.ClientModel/tests/TestFramework/Mocks/MockSyncAsyncExtensions.cs index ff7a58125b45..da2405a3257f 100644 --- a/sdk/core/System.ClientModel/tests/TestFramework/Mocks/MockSyncAsyncExtensions.cs +++ b/sdk/core/System.ClientModel/tests/TestFramework/Mocks/MockSyncAsyncExtensions.cs @@ -85,15 +85,15 @@ public static async Task WaitSyncOrAsync(this MockRetryPolicy policy, TimeSpan d } } - public static async Task ReadContentSyncOrAsync(this PipelineResponse response, CancellationToken cancellationToken, bool isAsync) + public static async Task BufferContentSyncOrAsync(this PipelineResponse response, CancellationToken cancellationToken, bool isAsync) { if (isAsync) { - return await response.ReadContentAsync(cancellationToken).ConfigureAwait(false); + return await response.BufferContentAsync(cancellationToken).ConfigureAwait(false); } else { - return response.ReadContent(cancellationToken); + return response.BufferContent(cancellationToken); } } }