129 instantiations of HttpResponseMessage
Aspire.Cli.Tests (40)
Commands\ExportCommandTests.cs (7)
246return new System.Net.Http.HttpResponseMessage(System.Net.HttpStatusCode.OK) 253return new System.Net.Http.HttpResponseMessage(System.Net.HttpStatusCode.OK) 260return new System.Net.Http.HttpResponseMessage(System.Net.HttpStatusCode.OK) 265return new System.Net.Http.HttpResponseMessage(System.Net.HttpStatusCode.NotFound); 723return new System.Net.Http.HttpResponseMessage(System.Net.HttpStatusCode.OK) 733return new System.Net.Http.HttpResponseMessage(System.Net.HttpStatusCode.OK) 740return new System.Net.Http.HttpResponseMessage(System.Net.HttpStatusCode.NotFound);
Commands\TelemetryTestHelper.cs (3)
94return new HttpResponseMessage(HttpStatusCode.OK) 104return new HttpResponseMessage(HttpStatusCode.OK) 111return new HttpResponseMessage(HttpStatusCode.NotFound);
Mcp\Docs\DocsFetcherTests.cs (16)
23using var response = new HttpResponseMessage 42using var response = new HttpResponseMessage 64using var response = new HttpResponseMessage 88using var response = new HttpResponseMessage 114using var response = new HttpResponseMessage 143return new HttpResponseMessage { StatusCode = HttpStatusCode.NotModified }; 146var response = new HttpResponseMessage 167using var response = new HttpResponseMessage 215using var response = new HttpResponseMessage 235using var response = new HttpResponseMessage 254using var response = new HttpResponseMessage 278using var response = new HttpResponseMessage 318using var response = new HttpResponseMessage 349return new HttpResponseMessage { StatusCode = HttpStatusCode.NotModified }; 351return new HttpResponseMessage 374return Task.FromResult(new HttpResponseMessage(HttpStatusCode.OK)
Mcp\ListStructuredLogsToolTests.cs (6)
158return new HttpResponseMessage(HttpStatusCode.OK) 165return new HttpResponseMessage(HttpStatusCode.OK) 261return new HttpResponseMessage(HttpStatusCode.OK) 268return new HttpResponseMessage(HttpStatusCode.OK) 316return new HttpResponseMessage(HttpStatusCode.OK) 323return new HttpResponseMessage(HttpStatusCode.OK)
Mcp\ListTracesToolTests.cs (8)
130return new HttpResponseMessage(HttpStatusCode.OK) 137return new HttpResponseMessage(HttpStatusCode.OK) 243return new HttpResponseMessage(HttpStatusCode.OK) 250return new HttpResponseMessage(HttpStatusCode.OK) 298return new HttpResponseMessage(HttpStatusCode.OK) 305return new HttpResponseMessage(HttpStatusCode.OK) 402return new HttpResponseMessage(HttpStatusCode.OK) 408return new HttpResponseMessage(HttpStatusCode.OK)
Aspire.Dashboard.Tests (7)
Telemetry\DashboardTelemetrySenderTests.cs (2)
84return Task.FromResult(new HttpResponseMessage(telemetryEnabledResponseStatusCode.Value) { Content = new StringContent(telemetryEnabledResponseBody ?? string.Empty) }); 92return Task.FromResult(new HttpResponseMessage(startTelemetryResponseStatusCode.Value));
Telemetry\DashboardTelemetryServiceTests.cs (5)
108return Task.FromResult(new HttpResponseMessage(HttpStatusCode.OK) 115return Task.FromResult(new HttpResponseMessage(HttpStatusCode.OK)); 119return Task.FromResult(new HttpResponseMessage(HttpStatusCode.OK)); 123return Task.FromResult(new HttpResponseMessage(HttpStatusCode.OK) 133return Task.FromResult(new HttpResponseMessage(HttpStatusCode.OK)
Aspire.Hosting.Tests (3)
Dcp\TestKubernetesService.cs (2)
44Response = new HttpResponseMessageWrapper(new HttpResponseMessage { StatusCode = System.Net.HttpStatusCode.NotFound }, "Not found") 119Response = new HttpResponseMessageWrapper(new HttpResponseMessage { StatusCode = System.Net.HttpStatusCode.NotFound }, ex.Message)
WithHttpCommandTests.cs (1)
267return Task.FromResult(new HttpResponseMessage(statusCode));
Microsoft.Arcade.Common (2)
ArcadeHttpMessageHandler.cs (2)
24return Task.FromResult(new HttpResponseMessage() 31return Task.FromResult(new HttpResponseMessage()
Microsoft.AspNetCore.InternalTesting (1)
HttpClientSlim.cs (1)
102new HttpResponseMessage(status).EnsureSuccessStatusCode();
Microsoft.AspNetCore.TestHost (1)
ClientHandler.cs (1)
192var response = new HttpResponseMessage();
Microsoft.AspNetCore.Testing.Tests (3)
TestResources\ReturningHttpClientHandler.cs (2)
16return new(HttpStatusCode.Gone); 22return Task.FromResult(new HttpResponseMessage(HttpStatusCode.Gone));
TestResources\TestHandler.cs (1)
16return Task.FromResult(new HttpResponseMessage(HttpStatusCode.OK));
Microsoft.Extensions.AI.Integration.Tests (2)
VerbatimHttpHandler.cs (1)
86return new() { Content = new StringContent(_expectedOutput) };
VerbatimMultiPartHttpHandler.cs (1)
143return new() { Content = new StringContent(sentJsonOutput, Encoding.UTF8, "application/json") };
Microsoft.Extensions.Http.Diagnostics.PerformanceTests (2)
NoRemoteCallHandler.cs (1)
37var response = new HttpResponseMessage
NoRemoteCallNotSeekableHandler.cs (1)
40var response = new HttpResponseMessage
Microsoft.Extensions.Http.Diagnostics.Tests (39)
Latency\Internal\HttpClientLatencyLogEnricherTest.cs (2)
46using HttpResponseMessage httpResponseMessage = new(); 66using HttpResponseMessage httpResponseMessage = new();
Logging\HttpClientLoggerTest.cs (14)
55using var httpResponseMessage = new HttpResponseMessage { StatusCode = responseCode }; 146new TestingHandlerStub((_, _) => Task.FromResult(new HttpResponseMessage(HttpStatusCode.OK)))); 193using var httpResponseMessage = new HttpResponseMessage 288using var httpResponseMessage = new HttpResponseMessage 396using var httpResponseMessage = new HttpResponseMessage 493using var httpResponseMessage = new HttpResponseMessage 608using var httpResponseMessage = new HttpResponseMessage 690new TestingHandlerStub((_, _) => Task.FromResult(new HttpResponseMessage(HttpStatusCode.OK)))); 733new TestingHandlerStub((_, _) => Task.FromResult(new HttpResponseMessage(HttpStatusCode.OK)))); 771(_, _) => Task.FromResult(new HttpResponseMessage(HttpStatusCode.OK)))); 879using var httpResponseMessage = new HttpResponseMessage 962Task.FromResult(new HttpResponseMessage((HttpStatusCode)httpStatusCode)))); 991using var httpResponseMessage = new HttpResponseMessage(); 1010using var httpResponseMessage = new HttpResponseMessage();
Logging\HttpClientLoggingExtensionsTest.cs (2)
418var response = new HttpResponseMessage(HttpStatusCode.OK); 453? new HttpResponseMessage(HttpStatusCode.OK)
Logging\HttpHeadersReaderTest.cs (4)
24using var httpResponse = new HttpResponseMessage(); 42using var httpResponse = new HttpResponseMessage(); 145using var httpResponse = new HttpResponseMessage { Content = responseContent }; 178using var httpResponse = new HttpResponseMessage();
Logging\HttpRequestReaderTest.cs (7)
93using var httpResponseMessage = new HttpResponseMessage 155using var httpResponseMessage = new HttpResponseMessage 226using var httpResponseMessage = new HttpResponseMessage 302using var httpResponseMessage = new HttpResponseMessage 435using var httpResponseMessage = new HttpResponseMessage 504using var httpResponseMessage = new HttpResponseMessage 574using var httpResponseMessage = new HttpResponseMessage
Logging\HttpResponseBodyReaderTest.cs (9)
48using var httpResponse = new HttpResponseMessage 66using var httpResponse = new HttpResponseMessage 84using var httpResponse = new HttpResponseMessage 109using var httpResponse = new HttpResponseMessage 129using var httpResponse = new HttpResponseMessage 153using var httpResponse = new HttpResponseMessage 180using var httpResponse = new HttpResponseMessage 220using var httpResponse = new HttpResponseMessage 249using var httpResponse = new HttpResponseMessage
Logging\Internal\NoRemoteCallHandler.cs (1)
31var response = new HttpResponseMessage
Microsoft.Extensions.Http.Resilience.PerformanceTests (1)
NoRemoteCallHandler.cs (1)
18_response = new HttpResponseMessage
Microsoft.Extensions.Http.Resilience.Tests (24)
Hedging\HedgingTests.cs (1)
334_responses.Enqueue(new HttpResponseMessage(statusCode));
Hedging\HttpClientHedgingResiliencePredicatesTests.cs (1)
42using var response = new HttpResponseMessage(code);
Hedging\StandardHedgingTests.cs (2)
116using var response = new HttpResponseMessage(HttpStatusCode.OK); 361return new HttpResponseMessage(HttpStatusCode.OK);
Helpers\TestHandlerStub.cs (1)
17: this((_, _) => Task.FromResult(new HttpResponseMessage(statusCode)))
Internal\RequestMessageSnapshotStrategyTests.cs (1)
29return new ValueTask<HttpResponseMessage>(new HttpResponseMessage());
Internal\RetryAfterHelperTests.cs (4)
19using var response = new HttpResponseMessage(); 31using var response = new HttpResponseMessage(); 44using var response = new HttpResponseMessage(); 58using var response = new HttpResponseMessage();
Polly\HttpCircuitBreakerStrategyOptionsTests.cs (1)
59using var response = new HttpResponseMessage { StatusCode = statusCode };
Polly\HttpClientResiliencePredicatesTests.cs (1)
55var response = new HttpResponseMessage { StatusCode = statusCode };
Polly\HttpRetryStrategyOptionsExtensionsTests.cs (4)
50using var response = new HttpResponseMessage { RequestMessage = request }; 62using var response = new HttpResponseMessage { RequestMessage = request }; 86using var response = new HttpResponseMessage { RequestMessage = null }; 109using var response = new HttpResponseMessage { RequestMessage = request };
Polly\HttpRetryStrategyOptionsTests.cs (4)
58var response = new HttpResponseMessage { StatusCode = statusCode }; 83var response = new HttpResponseMessage { StatusCode = statusCode }; 102using var responseMessage = new HttpResponseMessage(); 130using var responseMessage = new HttpResponseMessage
Resilience\HttpClientBuilderExtensionsTests.Standard.cs (1)
245return Task.FromResult(new HttpResponseMessage(HttpStatusCode.InternalServerError));
Resilience\HttpResilienceMetricsEnricherTests.cs (1)
46using var response = new HttpResponseMessage(System.Net.HttpStatusCode.InternalServerError);
Resilience\ResilienceHandlerTest.cs (2)
112return Task.FromResult(new HttpResponseMessage { StatusCode = HttpStatusCode.Created }); 137return Task.FromResult(new HttpResponseMessage { StatusCode = HttpStatusCode.Created });
System.Net.Http (3)
System\Net\Http\SocketsHttpHandler\Http2Stream.cs (1)
137_response = new HttpResponseMessage()
System\Net\Http\SocketsHttpHandler\Http3RequestStream.cs (1)
1094_response = new HttpResponseMessage()
System\Net\Http\SocketsHttpHandler\HttpConnection.cs (1)
665var response = new HttpResponseMessage() { RequestMessage = request, Content = new HttpConnectionResponseContent() };
System.Net.Http.WinHttpHandler (1)
System\Net\Http\WinHttpResponseParser.cs (1)
25var response = new HttpResponseMessage();
1023 references to HttpResponseMessage
aspire (17)
Commands\ExportCommand.cs (2)
263var response = await client.GetAsync(url, cancellationToken).ConfigureAwait(false); 294var response = await client.GetAsync(url, cancellationToken).ConfigureAwait(false);
Commands\TelemetryCommandHelpers.cs (2)
94public static bool HasJsonContentType(HttpResponseMessage response) 209var response = await client.GetAsync(url, cancellationToken).ConfigureAwait(false);
Commands\TelemetryLogsCommand.cs (2)
170var response = await client.GetAsync(url, cancellationToken); 196using var response = await client.GetAsync(url, HttpCompletionOption.ResponseHeadersRead, cancellationToken);
Commands\TelemetrySpansCommand.cs (2)
171var response = await client.GetAsync(url, cancellationToken); 197using var response = await client.GetAsync(url, HttpCompletionOption.ResponseHeadersRead, cancellationToken);
Commands\TelemetryTracesCommand.cs (2)
127var response = await client.GetAsync(url, cancellationToken); 208var response = await client.GetAsync(url, cancellationToken);
Mcp\Docs\DocsFetcher.cs (2)
52using var response = await _httpClient.SendAsync(request, cancellationToken).ConfigureAwait(false); 71using var retryResponse = await _httpClient.SendAsync(retryRequest, cancellationToken).ConfigureAwait(false);
Mcp\Tools\ListStructuredLogsTool.cs (1)
77var response = await client.GetAsync(url, cancellationToken).ConfigureAwait(false);
Mcp\Tools\ListTracesTool.cs (1)
77var response = await client.GetAsync(url, cancellationToken).ConfigureAwait(false);
Mcp\Tools\ListTraceStructuredLogsTool.cs (1)
77var response = await client.GetAsync(url, cancellationToken).ConfigureAwait(false);
Npm\SigstoreNpmProvenanceChecker.cs (1)
96var response = await httpClient.GetAsync(url, cancellationToken).ConfigureAwait(false);
Utils\CliDownloader.cs (1)
177using var response = await s_httpClient.GetAsync(url, HttpCompletionOption.ResponseHeadersRead, cts.Token);
Aspire.Cli.Tests (18)
Mcp\Docs\DocsFetcherTests.cs (13)
23using var response = new HttpResponseMessage 42using var response = new HttpResponseMessage 64using var response = new HttpResponseMessage 88using var response = new HttpResponseMessage 114using var response = new HttpResponseMessage 146var response = new HttpResponseMessage 167using var response = new HttpResponseMessage 215using var response = new HttpResponseMessage 235using var response = new HttpResponseMessage 254using var response = new HttpResponseMessage 278using var response = new HttpResponseMessage 318using var response = new HttpResponseMessage 369protected override Task<HttpResponseMessage> SendAsync(
Utils\MockHttpMessageHandler.cs (5)
12private readonly Func<HttpRequestMessage, HttpResponseMessage>? _responseFactory; 13private readonly HttpResponseMessage? _response; 27public MockHttpMessageHandler(HttpResponseMessage response, Action<HttpRequestMessage>? requestValidator = null) 37public MockHttpMessageHandler(Func<HttpRequestMessage, HttpResponseMessage> responseFactory) 51protected override Task<HttpResponseMessage> SendAsync(
Aspire.Dashboard (3)
Model\Assistant\ChatClientFactory.cs (1)
140using var httpResponse = await _httpClient.SendAsync(httpRequest, cancellationToken).ConfigureAwait(false);
Telemetry\DashboardTelemetrySender.cs (1)
142var response = await Client.GetAsync(TelemetryEndpoints.TelemetryEnabled).ConfigureAwait(false);
Telemetry\DashboardTelemetryService.cs (1)
357var httpResponseMessage = await client.PostAsJsonAsync(endpoint, request).ConfigureAwait(false);
Aspire.Dashboard.Tests (87)
Integration\FrontendBrowserTokenAuthTests.cs (6)
42var response = await client.GetAsync("/").DefaultTimeout(); 64var response1 = await client.GetAsync(DashboardUrls.LoginUrl(returnUrl: DashboardUrls.TracesUrl(), token: apiKey)).DefaultTimeout(); 71var response2 = await client.GetAsync(DashboardUrls.StructuredLogsUrl()).DefaultTimeout(); 95var response = await client.GetAsync(DashboardUrls.LoginUrl(returnUrl: DashboardUrls.TracesUrl(), token: apiKey)).DefaultTimeout(); 119var response = await client.GetAsync(DashboardUrls.LoginUrl(returnUrl: DashboardUrls.TracesUrl(), token: "Wrong!")).DefaultTimeout(); 144var response = await client.PostAsync("/api/validatetoken?token=" + requestToken, content: null).DefaultTimeout();
Integration\FrontendOpenIdConnectAuthTests.cs (2)
39var response = await client.GetAsync("/").DefaultTimeout(); 84var response = await client.GetAsync("/").DefaultTimeout();
Integration\HealthTests.cs (1)
33var response = await client.SendAsync(request).DefaultTimeout();
Integration\McpServiceTests.cs (12)
39var responseMessage = await httpClient.SendAsync(request).DefaultTimeout(TestConstants.LongTimeoutDuration); 66var responseMessage = await httpClient.SendAsync(request).DefaultTimeout(TestConstants.LongTimeoutDuration); 89var responseMessage = await httpClient.SendAsync(requestMessage).DefaultTimeout(TestConstants.LongTimeoutDuration); 116var responseMessage = await httpClient.SendAsync(listRequest).DefaultTimeout(TestConstants.LongTimeoutDuration); 141var responseMessage = await httpClient.SendAsync(request).DefaultTimeout(TestConstants.LongTimeoutDuration); 178var responseMessage = await httpClient.SendAsync(request).DefaultTimeout(TestConstants.LongTimeoutDuration); 210var responseMessage = await httpClient.SendAsync(request).DefaultTimeout(TestConstants.LongTimeoutDuration); 239var responseMessage = await httpClient.SendAsync(request).DefaultTimeout(TestConstants.LongTimeoutDuration); 277var responseMessage = await httpClient.SendAsync(request).DefaultTimeout(TestConstants.LongTimeoutDuration); 345var initResponse = await httpClient.SendAsync(initRequest).DefaultTimeout(TestConstants.LongTimeoutDuration); 370var notificationResponse = await httpClient.SendAsync(notificationRequest).DefaultTimeout(TestConstants.LongTimeoutDuration); 402internal static async Task<string?> GetDataFromSseResponseAsync(HttpResponseMessage response)
Integration\OtlpCorsHttpServiceTests.cs (5)
35var responseMessage = await httpClient.SendAsync(preflightRequest).DefaultTimeout(); 59var responseMessage1 = await httpClient.SendAsync(preflightRequest1).DefaultTimeout(); 73var responseMessage2 = await httpClient.SendAsync(preflightRequest2).DefaultTimeout(); 100var responseMessage = await httpClient.SendAsync(preflightRequest).DefaultTimeout(); 128var responseMessage = await httpClient.SendAsync(preflightRequest).DefaultTimeout();
Integration\OtlpHttpJsonTests.cs (8)
414var responseMessage = await httpClient.PostAsync("/v1/traces", content).DefaultTimeout(); 475var responseMessage = await httpClient.PostAsync("/v1/logs", content).DefaultTimeout(); 552var responseMessage = await httpClient.PostAsync("/v1/logs", content).DefaultTimeout(); 602var responseMessage = await httpClient.PostAsync("/v1/metrics", content).DefaultTimeout(); 663var responseMessage = await httpClient.SendAsync(requestMessage).DefaultTimeout(); 687var responseMessage = await httpClient.PostAsync("/v1/logs", content).DefaultTimeout(); 705var responseMessage = await httpClient.PostAsync("/v1/logs", content).DefaultTimeout(); 723var responseMessage = await httpClient.PostAsync("/v1/logs", content).DefaultTimeout();
Integration\OtlpHttpServiceTests.cs (12)
50var responseMessage = await httpClient.PostAsync("/v1/logs", content).DefaultTimeout(TestConstants.LongTimeoutDuration); 76var responseMessage = await httpClient.PostAsync("/v1/logs", content).DefaultTimeout(); 120var responseMessage = await httpClient.PostAsync("/v1/logs", content).DefaultTimeout(); 148var responseMessage = await httpClient.SendAsync(requestMessage).DefaultTimeout(); 176var responseMessage = await httpClient.SendAsync(requestMessage).DefaultTimeout(); 210var responseMessage = await httpClient.PostAsync("/v1/logs", content).DefaultTimeout(); 240var responseMessage = await client.PostAsync("/v1/logs", content).DefaultTimeout(); 271var responseMessage = await client.PostAsync("/v1/logs", content).DefaultTimeout(); 317var responseMessage = await client.SendAsync(requestMessage).DefaultTimeout(); 340var responseMessage = await client.PostAsync("/v1/logs", content).DefaultTimeout(); 369var responseMessage = await client.PostAsync("/v1/traces", content).DefaultTimeout(); 398var responseMessage = await client.PostAsync("/v1/metrics", content).DefaultTimeout();
Integration\ResponseCompressionTests.cs (2)
27var response = await client.SendAsync(request).DefaultTimeout(); 49var response = await client.SendAsync(request).DefaultTimeout();
Integration\StartupTests.cs (7)
343var response = await httpClient.SendAsync(request).DefaultTimeout(); 399var response = await browserHttpClient.SendAsync(request).DefaultTimeout(); 422var responseMessage = await mcpHttpClient.SendAsync(mcpRequest).DefaultTimeout(TestConstants.LongTimeoutDuration); 524var responseMessage = await httpClient.SendAsync(request).DefaultTimeout(); 831var response = await httpClient.GetAsync("/api/telemetry/spans").DefaultTimeout(); 987var response = await client.GetAsync("/").DefaultTimeout(); 1066var response = await client.SendAsync(request).DefaultTimeout();
Integration\TelemetryApiTests.cs (21)
105var response = await httpClient.GetAsync("/api/telemetry/spans").DefaultTimeout(); 125var response = await httpClient.GetAsync("/api/telemetry/spans").DefaultTimeout(); 151var response = await httpClient.GetAsync("/api/telemetry/spans").DefaultTimeout(); 178var response = await httpClient.GetAsync("/api/telemetry/spans").DefaultTimeout(); 197var response = await httpClient.GetAsync("/api/telemetry/logs").DefaultTimeout(); 219var response = await httpClient.GetAsync("/api/telemetry/logs?traceId=some-trace-id").DefaultTimeout(); 241var response = await httpClient.GetAsync("/api/telemetry/spans?hasError=true&limit=50").DefaultTimeout(); 262var response = await httpClient.GetAsync("/api/telemetry/spans?resource=unknown-resource").DefaultTimeout(); 281var response = await httpClient.GetAsync("/api/telemetry/logs?severity=Error&limit=50").DefaultTimeout(); 302var response = await httpClient.GetAsync("/api/telemetry/logs?resource=unknown-resource").DefaultTimeout(); 322var response = await httpClient.GetAsync("/api/telemetry/spans").DefaultTimeout(); 346var response = await httpClient.GetAsync("/api/telemetry/spans").DefaultTimeout(); 372var response = await httpClient.GetAsync("/api/telemetry/spans").DefaultTimeout(); 396var response = await httpClient.GetAsync("/api/telemetry/spans").DefaultTimeout(); 418var response = await httpClient.GetAsync("/api/telemetry/spans?follow=true", HttpCompletionOption.ResponseHeadersRead, cts.Token).DefaultTimeout(); 449var response = await httpClient.GetAsync("/api/telemetry/logs?follow=true", HttpCompletionOption.ResponseHeadersRead, cts.Token).DefaultTimeout(); 479var response = await httpClient.GetAsync("/api/telemetry/traces").DefaultTimeout(); 501var response = await httpClient.GetAsync("/api/telemetry/traces?hasError=true&limit=10").DefaultTimeout(); 523var response = await httpClient.GetAsync("/api/telemetry/traces?resource=unknownresource").DefaultTimeout(); 542var response = await httpClient.GetAsync("/api/telemetry/traces/nonexistent-trace-id").DefaultTimeout(); 565var response = await httpClient.GetAsync("/api/telemetry/traces").DefaultTimeout();
Middleware\ValidateTokenMiddlewareTests.cs (6)
22var response = await host.GetTestClient().GetAsync("/login?t=test").DefaultTimeout(); 30var response = await host.GetTestClient().GetAsync("/login?t=test&returnUrl=/test").DefaultTimeout(); 38var response = await host.GetTestClient().GetAsync("/login?t=wrong").DefaultTimeout(); 46var response = await host.GetTestClient().GetAsync("/login?t=wrong&returnUrl=/test").DefaultTimeout(); 54var response = await host.GetTestClient().GetAsync("/login?t=token").DefaultTimeout(); 62var response = await host.GetTestClient().GetAsync("/login?t=token&returnUrl=/test").DefaultTimeout();
Telemetry\DashboardTelemetrySenderTests.cs (5)
82return Task.FromException<HttpResponseMessage>(new InvalidOperationException()); 90return Task.FromException<HttpResponseMessage>(new InvalidOperationException()); 151private readonly Func<HttpRequestMessage, CancellationToken, Task<HttpResponseMessage>> _value; 153public TestHttpMessageHandler(Func<HttpRequestMessage, CancellationToken, Task<HttpResponseMessage>> value) 158protected override Task<HttpResponseMessage> SendAsync(HttpRequestMessage request, CancellationToken cancellationToken)
Aspire.EndToEnd.Tests (3)
IntegrationServicesTests.cs (1)
35var response = await _integrationServicesFixture.IntegrationServiceA.HttpGetAsync("http", $"/{resourceName}/verify", cancellationToken);
tests\Shared\TemplatesTesting\AspireProject.cs (1)
414var res = await Client.Value.GetAsync(dashboardUrl, token);
tests\Shared\TemplatesTesting\ProjectInfo.cs (1)
20public Task<HttpResponseMessage> HttpGetAsync(string bindingName, string path, CancellationToken cancellationToken = default)
Aspire.Hosting (5)
ApplicationModel\HttpCommandContext.cs (1)
79public required HttpResponseMessage Response { get; init; }
Dcp\DcpKubernetesClient.cs (3)
76var httpResponse = await SendRequest<object?>(url, HttpMethod.Get, customHeaders: null, body: null, cancellationToken).ConfigureAwait(false); 103var httpResponse = await SendRequestRaw(null, httpRequest, cancellationToken).ConfigureAwait(false); 133var httpResponse = await SendRequestRaw(content, httpRequest, cancellationToken).ConfigureAwait(false);
ResourceBuilderExtensions.cs (1)
2486var response = await httpClient.SendAsync(request, context.CancellationToken).ConfigureAwait(false);
Aspire.Hosting.Azure (1)
AcrLoginService.cs (1)
109var response = await httpClient.PostAsync(exchangeUrl, content, cancellationToken).ConfigureAwait(false);
Aspire.Hosting.GitHub.Models (2)
GitHubModelsHealthCheck.cs (2)
55using var response = await httpClient.SendAsync(request, cancellationToken).ConfigureAwait(false); 72private static async Task<HealthCheckResult> HandleErrorCode(HttpResponseMessage response, CancellationToken cancellationToken)
Aspire.Hosting.OpenAI (3)
OpenAIHealthCheck.cs (1)
69HttpResponseMessage resp;
OpenAIModelHealthCheck.cs (2)
45using var response = await httpClient.SendAsync(request, cancellationToken).ConfigureAwait(false); 64private static async Task<HealthCheckResult> HandleNotFound(HttpResponseMessage response, CancellationToken cancellationToken)
Aspire.Hosting.PostgreSQL.Tests (2)
PostgresFunctionalTests.cs (2)
91var response = await client.GetAsync(path); 176var response = await client.PostAsync("/api/connect", httpContent);
Aspire.Hosting.Redis.Tests (6)
RedisFunctionalTests.cs (6)
92var response = await client.GetAsync(path); 159var response = await client.GetAsync("/api/databases", cts.Token); 190var testConnectionResponse = await client.GetAsync($"/api/databases/{db.Id}/connect", cts2.Token); 567var response = await httpClient.GetAsync("/api/settings", ct); 599var response = await client.PatchAsync(apiUrl, jsonContent, ct); 637var httpResponse = await client.GetAsync(redisCommanderUrl!);
Aspire.Hosting.Seq.Tests (2)
SeqFunctionalTests.cs (2)
55var ingestResponse = await httpClient.PostAsync("/ingest/clef", content, token); 58var response = await httpClient.GetAsync("/api/events?filter=Username='johndoe'", token);
Aspire.Hosting.Tests (3)
ContainerTunnelTests.cs (2)
38var response = await clientA.GetAsync("/servicea/").DefaultTimeout(TestConstants.DefaultOrchestratorTestTimeout); 78var response = await clientA.GetAsync("/servicea/").DefaultTimeout(TestConstants.DefaultOrchestratorTestTimeout);
WithHttpCommandTests.cs (1)
264protected override Task<HttpResponseMessage> SendAsync(HttpRequestMessage request, CancellationToken cancellationToken)
Aspire.Hosting.Yarp.Tests (2)
YarpFunctionalTests.cs (2)
54using var response200 = await httpClient.GetAsync("/aspnetapp"); 57using var response404 = await httpClient.GetAsync("/another");
Aspire.Playground.Tests (4)
AppHostTests.cs (1)
94HttpResponseMessage? response = null;
Infrastructure\DistributedApplicationExtensions.cs (2)
221using var checkResponse = await checkHttpClient.PostAsync("/ApplyDatabaseMigrations", emptyDbContextContent); 252using var response = await applyMigrationsHttpClient.PostAsync("/ApplyDatabaseMigrations", content);
ProjectSpecificTests.cs (1)
82var response = await AppHostTests.CreateHttpClientWithResilience(app, "funcapp").GetAsync("/api/injected-resources");
Aspire.Seq (1)
SeqHealthCheck.cs (1)
21using var response = await _client.GetAsync("/health", cancellationToken)
Aspire.Templates.Tests (2)
tests\Shared\TemplatesTesting\AspireProject.cs (1)
414var res = await Client.Value.GetAsync(dashboardUrl, token);
tests\Shared\TemplatesTesting\ProjectInfo.cs (1)
20public Task<HttpResponseMessage> HttpGetAsync(string bindingName, string path, CancellationToken cancellationToken = default)
Binding.Http.IntegrationTests (7)
BasicHttpBindingTests.4.0.0.cs (2)
118return Task.FromResult((HttpResponseMessage)null); 176return Task.FromResult((HttpResponseMessage)null);
HttpBindingTestHelpers.cs (5)
30public Func<HttpRequestMessage, CancellationToken, Task<HttpResponseMessage>> OnSendingAsync { get; set; } 31public Func<HttpResponseMessage, CancellationToken, Task<HttpResponseMessage>> OnSentAsync { get; set; } 45protected override async Task<HttpResponseMessage> SendAsync(HttpRequestMessage request, CancellationToken cancellationToken) 47HttpResponseMessage response;
Binding.ReliableSession.IntegrationTests (7)
NetHttpBindingTests.cs (1)
378return Task.FromResult<HttpResponseMessage>(null);
src\System.Private.ServiceModel\tests\Scenarios\Binding\Http\HttpBindingTestHelpers.cs (5)
30public Func<HttpRequestMessage, CancellationToken, Task<HttpResponseMessage>> OnSendingAsync { get; set; } 31public Func<HttpResponseMessage, CancellationToken, Task<HttpResponseMessage>> OnSentAsync { get; set; } 45protected override async Task<HttpResponseMessage> SendAsync(HttpRequestMessage request, CancellationToken cancellationToken) 47HttpResponseMessage response;
WSHttpBindingTests.cs (1)
378return Task.FromResult<HttpResponseMessage>(null);
DevTunnels.ApiService (1)
Program.cs (1)
15var response = await http.GetAsync("/");
dotnet (1)
NugetSearch\NugetToolSearchApiRequest.cs (1)
30HttpResponseMessage response = await httpClient.GetAsync(queryUrl, cancellation.Token);
dotnet-openapi (3)
HttpClientWrapper.cs (3)
31var response = await _client.GetAsync(url); 44private readonly HttpResponseMessage _response; 46public HttpResponseMessageWrapper(HttpResponseMessage response)
dotnet-sourcelink (1)
dotnet-svcutil-lib (15)
FrameworkFork\System.ServiceModel\System\ServiceModel\Channels\HttpChannelFactory.cs (1)
879private HttpResponseMessage _httpResponseMessage;
FrameworkFork\System.ServiceModel\System\ServiceModel\Channels\HttpChannelHelpers.cs (2)
112public static HttpResponseMessage ProcessGetResponseWebException(HttpRequestException requestException, HttpRequestMessage request, HttpAbortReason abortReason) 147internal static Exception CreateUnexpectedResponseException(HttpResponseMessage response)
FrameworkFork\System.ServiceModel\System\ServiceModel\Channels\HttpResponseMessageExtensionMethods.cs (4)
15internal static void CopyPropertiesFromMessage(this HttpResponseMessage httpResponseMessage, Message message) 29internal static bool CreateContentIfNull(this HttpResponseMessage httpResponseMessage) 42internal static void MergeWebHeaderCollection(this HttpResponseMessage responseMessage, WebHeaderCollection headersToMerge) 48internal static WebHeaderCollection ToWebHeaderCollection(this HttpResponseMessage httpResponse)
FrameworkFork\System.ServiceModel\System\ServiceModel\Channels\HttpResponseMessageHelper.cs (2)
21private readonly HttpResponseMessage _httpResponseMessage; 25public HttpResponseMessageHelper(HttpResponseMessage httpResponseMessage, HttpChannelFactory<IRequestChannel> factory)
FrameworkFork\System.ServiceModel\System\ServiceModel\Channels\HttpResponseMessageProperty.cs (6)
31internal HttpResponseMessageProperty(HttpResponseMessage httpResponseMessage) 153public HttpResponseMessage HttpResponseMessage 166internal static HttpResponseMessage GetHttpResponseMessageFromMessage(Message message) 168HttpResponseMessage httpResponseMessage = null; 291public HttpResponseMessageBackedProperty(HttpResponseMessage httpResponseMessage) 298public HttpResponseMessage HttpResponseMessage { get; private set; }
GenerateDocumentationAndConfigFiles (1)
Program.cs (1)
856using var response = await httpClient.SendAsync(request, cancellationToken).ConfigureAwait(false);
Infrastructure.Common (3)
ServiceUtilHelper.cs (3)
576HttpResponseMessage response = httpClient.GetAsync(requestUri).GetAwaiter().GetResult(); 595HttpResponseMessage response = httpClient.GetAsync(requestUri).GetAwaiter().GetResult(); 614HttpResponseMessage response = await httpClient.GetAsync(requestUri);
installer.tasks (1)
StaticFileRegeneration\RegenerateThirdPartyNotices.cs (1)
74HttpResponseMessage response = await client.GetAsync(c.Url);
Keycloak.Web (1)
AuthorizationHandler.cs (1)
8protected override async Task<HttpResponseMessage> SendAsync(HttpRequestMessage request, CancellationToken cancellationToken)
Microsoft.Arcade.Common (3)
ArcadeHttpMessageHandler.cs (2)
15public Task<HttpResponseMessage> SendAsync(HttpRequestMessage request) => SendAsync(request, CancellationToken.None); 17protected override Task<HttpResponseMessage> SendAsync(HttpRequestMessage request, CancellationToken cancellationToken)
RequestResponseHelper.cs (1)
14public HttpResponseMessage ResponseMessage { get; set;}
Microsoft.AspNetCore.Authentication.Facebook (1)
FacebookHandler.cs (1)
52var response = await Backchannel.GetAsync(endpoint, Context.RequestAborted);
Microsoft.AspNetCore.Authentication.Google (1)
GoogleHandler.cs (1)
50var response = await Backchannel.SendAsync(request, Context.RequestAborted);
Microsoft.AspNetCore.Authentication.MicrosoftAccount (1)
MicrosoftAccountHandler.cs (1)
46var response = await Backchannel.SendAsync(request, Context.RequestAborted);
Microsoft.AspNetCore.Authentication.OAuth (2)
OAuthHandler.cs (2)
222var response = await Backchannel.SendAsync(requestMessage, Context.RequestAborted); 232private static OAuthTokenResponse PrepareFailedOAuthTokenResponse(HttpResponseMessage response, string body)
Microsoft.AspNetCore.Authentication.OpenIdConnect (5)
OpenIdConnectHandler.cs (5)
600var parResponseMessage = await Backchannel.SendAsync(requestMessage, Context.RequestAborted); 609private async Task<string> GetPushedAuthorizationRequestUri(HttpResponseMessage parResponseMessage) 995var responseMessage = await Backchannel.SendAsync(requestMessage, Context.RequestAborted); 1061var responseMessage = await Backchannel.SendAsync(requestMessage, Context.RequestAborted); 1514private OpenIdConnectProtocolException CreateOpenIdConnectProtocolException(OpenIdConnectMessage message, HttpResponseMessage? response)
Microsoft.AspNetCore.Authentication.Twitter (5)
TwitterHandler.cs (5)
183private async Task<HttpResponseMessage> ExecuteRequestAsync(string url, HttpMethod httpMethod, RequestToken? accessToken = null, Dictionary<string, string>? extraOAuthPairs = null, Dictionary<string, string>? queryParameters = null, Dictionary<string, string>? formData = null) 273var response = await ExecuteRequestAsync(TwitterDefaults.RequestTokenEndpoint, HttpMethod.Post, extraOAuthPairs: new Dictionary<string, string>() { { "oauth_callback", callBackUri } }); 299var response = await ExecuteRequestAsync(TwitterDefaults.AccessTokenEndpoint, HttpMethod.Post, token, formData: formPost); 324var response = await ExecuteRequestAsync("https://api.twitter.com/1.1/account/verify_credentials.json", HttpMethod.Get, accessToken, queryParameters: new Dictionary<string, string>() { { "include_email", "true" } }); 356private async Task EnsureTwitterRequestSuccess(HttpResponseMessage response)
Microsoft.AspNetCore.Components.Testing (1)
Infrastructure\ReadinessNotificationService.cs (1)
53var response = await client.PostAsync(url, content: null).ConfigureAwait(false);
Microsoft.AspNetCore.Diagnostics.Middleware.Tests (27)
Latency\ChecpointAcceptanceTests.cs (2)
103HttpResponseMessage? response = null; 127using var response = await host.GetTestServer().CreateClient().GetAsync("/Path");
Logging\AcceptanceTests.cs (19)
217using var response = await client.PostAsync("/", content).ConfigureAwait(false); 277using var response = await client.PostAsync("/myroute/123", content).ConfigureAwait(false); 330using var response = await client.PostAsync("/myroute/123", content).ConfigureAwait(false); 384using var response = await client.SendAsync(request).ConfigureAwait(false); 445using var response = await client.SendAsync(httpMessage).ConfigureAwait(false); 493using var response = await client.DeleteAsync("/").ConfigureAwait(false); 535using var response = await client.GetAsync(RequestPath).ConfigureAwait(false); 565using var response = await client.DeleteAsync("/").ConfigureAwait(false); 598using var firstResponse = await client.DeleteAsync("/").ConfigureAwait(false); 603using var secondResponse = await client.DeleteAsync("/").ConfigureAwait(false); 756using var response = await client.PostAsync("/", content).ConfigureAwait(false); 786using var response = await client.GetAsync(httpPath).ConfigureAwait(false); 825using HttpResponseMessage response = await client.GetAsync("/flushrequestlogs").ConfigureAwait(false); 836using HttpResponseMessage response2 = await client.GetAsync("/flushalllogs").ConfigureAwait(false); 880using HttpResponseMessage response2 = await client.GetAsync("/flushalllogs").ConfigureAwait(false); 927using HttpResponseMessage response2 = await client.GetAsync("/flushalllogs").ConfigureAwait(false); 928using HttpResponseMessage response3 = await client.GetAsync("/logatrequest").ConfigureAwait(false); 965using var response = await client.GetAsync("").ConfigureAwait(false); 981using var response = await client.GetAsync("").ConfigureAwait(false);
Logging\AcceptanceTests.Mvc.cs (5)
65using var response = await client.GetAsync($"/api/users/{UserId}/someTestData?{QueryParamName}=foo").ConfigureAwait(false); 100using var response = await client.GetAsync($"/api/users/{UserId}/someTestData?{QueryParamName}=foo").ConfigureAwait(false); 146using var response = await client.GetAsync($"/api/users/{UserId}/{NoDataClassParamValue}?{QueryParamName}=foo").ConfigureAwait(false); 190using var response = await client.GetAsync($"/api/users/{UserId}/someTestData?{QueryParamName}=foo").ConfigureAwait(false); 231using var response = await client.GetAsync(RequestPath).ConfigureAwait(false);
Logging\AcceptanceTests.Routing.cs (1)
65using var response = await client.GetAsync(httpPath).ConfigureAwait(false);
Microsoft.AspNetCore.HeaderPropagation (1)
HeaderPropagationMessageHandler.cs (1)
41protected override Task<HttpResponseMessage> SendAsync(HttpRequestMessage request, CancellationToken cancellationToken)
Microsoft.AspNetCore.Http.Connections.Client (15)
HttpConnection.cs (2)
489using (var response = await httpClient.SendAsync(request, HttpCompletionOption.ResponseHeadersRead, cancellationToken).ConfigureAwait(false)) 770using var response = await _httpClient.SendAsync(request, HttpCompletionOption.ResponseHeadersRead, cancellationToken).ConfigureAwait(false);
Internal\AccessTokenHttpMessageHandler.cs (2)
22protected override async Task<HttpResponseMessage> SendAsync(HttpRequestMessage request, CancellationToken cancellationToken) 55var result = await base.SendAsync(request, cancellationToken).ConfigureAwait(false);
Internal\Http2HttpMessageHandler.cs (1)
20protected override Task<HttpResponseMessage> SendAsync(HttpRequestMessage request, CancellationToken cancellationToken)
Internal\LoggingHttpMessageHandler.cs (2)
25protected override async Task<HttpResponseMessage> SendAsync(HttpRequestMessage request, CancellationToken cancellationToken) 29var response = await base.SendAsync(request, cancellationToken).ConfigureAwait(false);
Internal\LongPollingTransport.cs (3)
57using (var response = await _httpClient.SendAsync(request, cancellationToken).ConfigureAwait(false)) 156HttpResponseMessage response; 235var response = await _httpClient.SendAsync(request).ConfigureAwait(false);
Internal\LongPollingTransport.Log.cs (1)
44public static void PollResponseReceived(ILogger logger, HttpResponseMessage response)
Internal\SendUtils.cs (1)
51using (var response = await httpClient.SendAsync(request, HttpCompletionOption.ResponseHeadersRead, cancellationToken).ConfigureAwait(false))
Internal\ServerSentEventsTransport.cs (3)
58HttpResponseMessage? response = null; 88private async Task ProcessAsync(Uri url, HttpResponseMessage response) 126private async Task ProcessEventStream(HttpResponseMessage response, CancellationToken cancellationToken)
Microsoft.AspNetCore.Mvc.Testing (8)
Handlers\CookieContainerHandler.cs (3)
12/// more pairs of <see cref="HttpRequestMessage"/> and <see cref="HttpResponseMessage"/>. 41protected override async Task<HttpResponseMessage> SendAsync(HttpRequestMessage request, CancellationToken cancellationToken) 50var response = await base.SendAsync(request, cancellationToken);
Handlers\RedirectHandler.cs (5)
45protected override async Task<HttpResponseMessage> SendAsync(HttpRequestMessage request, CancellationToken cancellationToken) 51var response = await base.SendAsync(request, cancellationToken); 133HttpResponseMessage response, 167private static bool ShouldKeepVerb(HttpResponseMessage response) => 171private static bool IsRedirect(HttpResponseMessage response) =>
Microsoft.AspNetCore.Server.IntegrationTesting (6)
Common\LoggingHandler.cs (2)
18protected override async Task<HttpResponseMessage> SendAsync(HttpRequestMessage request, CancellationToken cancellationToken) 23var response = await base.SendAsync(request, cancellationToken);
Common\RetryHelper.cs (3)
19public static async Task<HttpResponseMessage> RetryRequest( 20Func<Task<HttpResponseMessage>> retryBlock, 36var response = await retryBlock().ConfigureAwait(false);
Deployers\NginxDeployer.cs (1)
81var response = await RetryHelper.RetryRequest(() =>
Microsoft.AspNetCore.SpaProxy (2)
SpaProxyLaunchManager.cs (2)
81var response = await httpClient.GetAsync(_options.ServerUrl, cancellationTokenSource.Token); 112var response = await httpClient.GetAsync(_options.ServerUrl, cancellationTokenSource.Token);
Microsoft.AspNetCore.SpaServices.Extensions (2)
Proxying\SpaProxy.cs (2)
86using (var responseMessage = await httpClient.SendAsync( 165private static async Task CopyProxyHttpResponse(HttpContext context, HttpResponseMessage responseMessage, CancellationToken cancellationToken)
Microsoft.AspNetCore.TestHost (10)
ClientHandler.cs (4)
58protected override HttpResponseMessage Send( 73/// <returns>A <see cref="Task{TResult}"/> returning the <see cref="HttpResponseMessage"/>.</returns> 74protected override async Task<HttpResponseMessage> SendAsync( 192var response = new HttpResponseMessage();
RequestBuilder.cs (6)
71/// <returns>The resulting <see cref="HttpResponseMessage"/>.</returns> 72public Task<HttpResponseMessage> SendAsync(string method) 81/// <returns>The resulting <see cref="HttpResponseMessage"/>.</returns> 82public Task<HttpResponseMessage> GetAsync() 91/// <returns>The resulting <see cref="HttpResponseMessage"/>.</returns> 92public Task<HttpResponseMessage> PostAsync()
Microsoft.AspNetCore.Testing.Tests (4)
FakesExtensionsTests.cs (1)
89using var response = await client.SendAsync(new HttpRequestMessage());
TestResources\ReturningHttpClientHandler.cs (2)
14protected override HttpResponseMessage Send(HttpRequestMessage request, CancellationToken cancellationToken) 20protected override Task<HttpResponseMessage> SendAsync(HttpRequestMessage request, CancellationToken cancellationToken)
TestResources\TestHandler.cs (1)
13protected override Task<HttpResponseMessage> SendAsync(HttpRequestMessage request,
Microsoft.Build.Tasks.Core (2)
DownloadFile.cs (2)
157using (HttpResponseMessage response = await client.GetAsync(uri, HttpCompletionOption.ResponseHeadersRead, cancellationToken).ConfigureAwait(false)) 353private bool ShouldSkip(HttpResponseMessage response, FileInfo destinationFile)
Microsoft.Deployment.DotNet.Releases (2)
Utils.cs (2)
31HttpResponseMessage httpResponse = await s_httpClient.SendAsync(httpRequest).ConfigureAwait(false); 64HttpResponseMessage httpResponse = await s_httpClient.GetAsync(address).ConfigureAwait(false);
Microsoft.DotNet.Arcade.Sdk (1)
src\DownloadFile.cs (1)
180var httpResponse = await httpClient.GetAsync(uri, _cancellationSource.Token).ConfigureAwait(false);
Microsoft.DotNet.HotReload.WebAssembly.Browser (1)
WebAssemblyHotReload.cs (1)
96var response = await client.GetAsync("/_framework/blazor-hotreload");
Microsoft.Extensions.AI.Evaluation.Safety (6)
ContentSafetyService.cs (6)
201HttpResponseMessage response = 252HttpResponseMessage response = 308HttpResponseMessage response = 357HttpResponseMessage response; 406private async ValueTask<HttpResponseMessage> GetResponseAsync( 419HttpResponseMessage response = await _httpClient.SendAsync(request, cancellationToken).ConfigureAwait(false);
Microsoft.Extensions.AI.Integration.Tests (3)
VerbatimHttpHandler.cs (2)
44protected override async Task<HttpResponseMessage> SendAsync(HttpRequestMessage request, CancellationToken cancellationToken) 79using var response = await base.SendAsync(request, cancellationToken).ConfigureAwait(false);
VerbatimMultiPartHttpHandler.cs (1)
44protected override async Task<HttpResponseMessage> SendAsync(
Microsoft.Extensions.AI.OpenAI.Tests (1)
ThrowUserAgentExceptionHandler.cs (1)
13protected override Task<HttpResponseMessage> SendAsync(HttpRequestMessage request, CancellationToken cancellationToken) =>
Microsoft.Extensions.DataIngestion.Tests (4)
Readers\DocumentReaderConformanceTests.cs (4)
81using HttpResponseMessage response = await DownloadAsync(new(source)); 153protected static async Task<HttpResponseMessage> DownloadAsync(Uri uri) 157HttpResponseMessage response = await _httpClient.GetAsync(uri); 181using HttpResponseMessage response = await DownloadAsync(uri);
Microsoft.Extensions.Http (23)
HttpMessageHandlerBuilder.cs (1)
73/// of sending an <see cref="HttpRequestMessage"/> and receiving an <see cref="HttpResponseMessage"/>.
Logging\HttpClientLoggerHandler.cs (4)
25protected override async Task<HttpResponseMessage> SendAsync(HttpRequestMessage request, CancellationToken cancellationToken) 30HttpResponseMessage? response = null; 65protected override HttpResponseMessage Send(HttpRequestMessage request, CancellationToken cancellationToken) 70HttpResponseMessage? response = null;
Logging\IHttpClientAsyncLogger.cs (3)
24/// <see cref="HttpResponseMessage"/> properties, such as reading from a content stream; if possible, such behavior should be avoided. 51ValueTask LogRequestStopAsync(object? context, HttpRequestMessage request, HttpResponseMessage response, TimeSpan elapsed, CancellationToken cancellationToken = default); 63ValueTask LogRequestFailedAsync(object? context, HttpRequestMessage request, HttpResponseMessage? response, Exception exception, TimeSpan elapsed, CancellationToken cancellationToken = default);
Logging\IHttpClientLogger.cs (3)
16/// <see cref="HttpResponseMessage"/> properties, such as reading from a content stream; if possible, such behavior should be avoided. 39void LogRequestStop(object? context, HttpRequestMessage request, HttpResponseMessage response, TimeSpan elapsed); 49void LogRequestFailed(object? context, HttpRequestMessage request, HttpResponseMessage? response, Exception exception, TimeSpan elapsed);
Logging\LoggingHttpMessageHandler.cs (5)
49private Task<HttpResponseMessage> SendCoreAsync(HttpRequestMessage request, bool useAsync, CancellationToken cancellationToken) 54async Task<HttpResponseMessage> Core(HttpRequestMessage request, bool useAsync, CancellationToken cancellationToken) 65HttpResponseMessage response = useAsync 86protected override Task<HttpResponseMessage> SendAsync(HttpRequestMessage request, CancellationToken cancellationToken) 92protected override HttpResponseMessage Send(HttpRequestMessage request, CancellationToken cancellationToken)
Logging\LoggingScopeHttpMessageHandler.cs (5)
48private Task<HttpResponseMessage> SendCoreAsync(HttpRequestMessage request, bool useAsync, CancellationToken cancellationToken) 53async Task<HttpResponseMessage> Core(HttpRequestMessage request, bool useAsync, CancellationToken cancellationToken) 65HttpResponseMessage response = useAsync 87protected override Task<HttpResponseMessage> SendAsync(HttpRequestMessage request, CancellationToken cancellationToken) 93protected override HttpResponseMessage Send(HttpRequestMessage request, CancellationToken cancellationToken)
Logging\LogHelper.cs (2)
87public static void LogRequestEnd(this ILogger logger, HttpResponseMessage response, TimeSpan duration, Func<string, bool> shouldRedactHeaderValue) 126public static void LogRequestPipelineEnd(this ILogger logger, HttpResponseMessage response, TimeSpan duration, Func<string, bool> shouldRedactHeaderValue)
Microsoft.Extensions.Http.Diagnostics (22)
Latency\Internal\HttpClientLatencyLogEnricher.cs (1)
39public void Enrich(IEnrichmentTagCollector collector, HttpRequestMessage? request, HttpResponseMessage? response, Exception? exception)
Latency\Internal\HttpLatencyMediator.cs (1)
29public void RecordEnd(ILatencyContext latencyContext, HttpResponseMessage? response = null)
Latency\Internal\HttpLatencyTelemetryHandler.cs (1)
45protected async override Task<HttpResponseMessage> SendAsync(HttpRequestMessage request, CancellationToken cancellationToken)
Logging\IHttpClientLogEnricher.cs (2)
20/// <param name="response"><see cref="HttpResponseMessage"/> object associated with the outgoing HTTP request.</param> 26void Enrich(IEnrichmentTagCollector collector, HttpRequestMessage request, HttpResponseMessage? response, Exception? exception);
Logging\Internal\HttpClientLogger.cs (6)
113HttpResponseMessage response, 121HttpResponseMessage? response, 130public void LogRequestStop(object? context, HttpRequestMessage request, HttpResponseMessage response, TimeSpan elapsed) 133public void LogRequestFailed(object? context, HttpRequestMessage request, HttpResponseMessage? response, Exception exception, TimeSpan elapsed) 153HttpResponseMessage? response, 219HttpRequestMessage request, HttpResponseMessage? response, Exception? exception)
Logging\Internal\HttpHeadersReader.cs (1)
55public void ReadResponseHeaders(HttpResponseMessage response, List<KeyValuePair<string, string>>? destination)
Logging\Internal\HttpRequestReader.cs (1)
100public async Task ReadResponseAsync(LogRecord logRecord, HttpResponseMessage response,
Logging\Internal\HttpResponseBodyReader.cs (3)
47public ValueTask<string> ReadAsync(HttpResponseMessage response, CancellationToken cancellationToken) 63private static async ValueTask<string> ReadFromStreamWithTimeoutAsync(HttpResponseMessage response, TimeSpan readTimeout, int readSizeLimit, CancellationToken cancellationToken) 91private static async ValueTask<string> ReadFromStreamAsync(HttpResponseMessage response, int readSizeLimit, CancellationToken cancellationToken)
Logging\Internal\IHttpHeadersReader.cs (2)
25/// <param name="response">An instance of <see cref="HttpResponseMessage"/> to read headers from.</param> 27void ReadResponseHeaders(HttpResponseMessage response, List<KeyValuePair<string, string>>? destination);
Logging\Internal\IHttpRequestReader.cs (3)
12/// Methods to read <see cref="HttpResponseMessage"/> or <see cref="HttpRequestMessage"/>. 17/// Reads <see cref="HttpResponseMessage"/>. 24Task ReadResponseAsync(LogRecord record, HttpResponseMessage response,
Logging\Internal\Log.cs (1)
14/// Logs <see cref="HttpRequestMessage"/>, <see cref="HttpResponseMessage"/> and the exceptions due to errors of request/response.
Microsoft.Extensions.Http.Diagnostics.PerformanceTests (101)
BenchEnricher.cs (1)
15public void Enrich(IEnrichmentTagCollector collector, HttpRequestMessage request, HttpResponseMessage? response, Exception? exception)
Benchmarks\HugeHttpCLientLoggingBenchmark.cs (32)
45public async Task<HttpResponseMessage> Huge_No_Log_HeadersRead() 47var response = await _hugeNoLog.SendAsync(Request, HttpCompletionOption.ResponseHeadersRead, CancellationToken.None) 55public async Task<HttpResponseMessage> Huge_No_Log_ContentRead() 57var response = await _hugeNoLog.SendAsync(Request, HttpCompletionOption.ResponseContentRead, CancellationToken.None) 65public async Task<HttpResponseMessage> Huge_Log_All_HeadersRead() 67var response = await _hugeLogAll.SendAsync(Request, HttpCompletionOption.ResponseHeadersRead, CancellationToken.None) 75public async Task<HttpResponseMessage> Huge_Log_All_ContentRead() 77var response = await _hugeLogAll.SendAsync(Request, HttpCompletionOption.ResponseContentRead, CancellationToken.None) 85public async Task<HttpResponseMessage> Huge_Log_Request_HeadersRead() 87var response = await _hugeLogRequest.SendAsync(Request, HttpCompletionOption.ResponseHeadersRead, CancellationToken.None) 95public async Task<HttpResponseMessage> Huge_Log_Request_ContentRead() 97var response = await _hugeLogRequest.SendAsync(Request, HttpCompletionOption.ResponseContentRead, CancellationToken.None) 105public async Task<HttpResponseMessage> Huge_Log_Response_HeadersRead() 107var response = await _hugeLogResponse.SendAsync(Request, HttpCompletionOption.ResponseHeadersRead, CancellationToken.None) 115public async Task<HttpResponseMessage> Huge_Log_Response_ContentRead() 117var response = await _hugeLogResponse.SendAsync(Request, HttpCompletionOption.ResponseContentRead, CancellationToken.None) 125public async Task<HttpResponseMessage> Huge_No_Log_HeadersRead_ChunkedEncoding() 127var response = await _hugeNoLogChunked.SendAsync(Request, HttpCompletionOption.ResponseHeadersRead, CancellationToken.None) 135public async Task<HttpResponseMessage> Huge_No_Log_ContentRead_ChunkedEncoding() 137var response = await _hugeNoLogChunked.SendAsync(Request, HttpCompletionOption.ResponseContentRead, CancellationToken.None) 145public async Task<HttpResponseMessage> Huge_Log_All_HeadersRead_ChunkedEncoding() 147var response = await _hugeLogAllChunked.SendAsync(Request, HttpCompletionOption.ResponseHeadersRead, CancellationToken.None) 155public async Task<HttpResponseMessage> Huge_Log_All_ContentRead_ChunkedEncoding() 157var response = await _hugeLogAllChunked.SendAsync(Request, HttpCompletionOption.ResponseContentRead, CancellationToken.None) 165public async Task<HttpResponseMessage> Huge_Log_Request_HeadersRead_ChunkedEncoding() 167var response = await _hugeLogRequestChunked.SendAsync(Request, HttpCompletionOption.ResponseHeadersRead, CancellationToken.None) 175public async Task<HttpResponseMessage> Huge_Log_Request_ContentRead_ChunkedEncoding() 177var response = await _hugeLogRequestChunked.SendAsync(Request, HttpCompletionOption.ResponseContentRead, CancellationToken.None) 185public async Task<HttpResponseMessage> Huge_Log_Response_HeadersRead_ChunkedEncoding() 187var response = await _hugeLogResponseChunked.SendAsync(Request, HttpCompletionOption.ResponseHeadersRead, CancellationToken.None) 195public async Task<HttpResponseMessage> Huge_Log_Response_ContentRead_ChunkedEncoding() 197var response = await _hugeLogResponseChunked.SendAsync(Request, HttpCompletionOption.ResponseContentRead, CancellationToken.None)
Benchmarks\MediumHttpClientLoggingBenchmark.cs (32)
45public async Task<HttpResponseMessage> Medium_No_Log_HeadersRead() 47var response = await _mediumNoLog.SendAsync(Request, HttpCompletionOption.ResponseHeadersRead, CancellationToken.None) 55public async Task<HttpResponseMessage> Medium_No_Log_ContentRead() 57var response = await _mediumNoLog.SendAsync(Request, HttpCompletionOption.ResponseContentRead, CancellationToken.None) 65public async Task<HttpResponseMessage> Medium_Log_All_HeadersRead() 67var response = await _mediumLogAll.SendAsync(Request, HttpCompletionOption.ResponseHeadersRead, CancellationToken.None) 75public async Task<HttpResponseMessage> Medium_Log_All_ContentRead() 77var response = await _mediumLogAll.SendAsync(Request, HttpCompletionOption.ResponseContentRead, CancellationToken.None) 85public async Task<HttpResponseMessage> Medium_Log_Request_HeadersRead() 87var response = await _mediumLogRequest.SendAsync(Request, HttpCompletionOption.ResponseHeadersRead, CancellationToken.None) 95public async Task<HttpResponseMessage> Medium_Log_Request_ContentRead() 97var response = await _mediumLogRequest.SendAsync(Request, HttpCompletionOption.ResponseContentRead, CancellationToken.None) 105public async Task<HttpResponseMessage> Medium_Log_Response_HeadersRead() 107var response = await _mediumLogResponse.SendAsync(Request, HttpCompletionOption.ResponseHeadersRead, CancellationToken.None) 115public async Task<HttpResponseMessage> Medium_Log_Response_ContentRead() 117var response = await _mediumLogResponse.SendAsync(Request, HttpCompletionOption.ResponseContentRead, CancellationToken.None) 125public async Task<HttpResponseMessage> Medium_No_Log_HeadersRead_ChunkedEncoding() 127var response = await _mediumNoLogChunked.SendAsync(Request, HttpCompletionOption.ResponseHeadersRead, CancellationToken.None) 135public async Task<HttpResponseMessage> Medium_No_Log_ContentRead_ChunkedEncoding() 137var response = await _mediumNoLogChunked.SendAsync(Request, HttpCompletionOption.ResponseContentRead, CancellationToken.None) 145public async Task<HttpResponseMessage> Medium_Log_All_HeadersRead_ChunkedEncoding() 147var response = await _mediumLogAllChunked.SendAsync(Request, HttpCompletionOption.ResponseHeadersRead, CancellationToken.None) 155public async Task<HttpResponseMessage> Medium_Log_All_ContentRead_ChunkedEncoding() 157var response = await _mediumLogAllChunked.SendAsync(Request, HttpCompletionOption.ResponseContentRead, CancellationToken.None) 165public async Task<HttpResponseMessage> Medium_Log_Request_HeadersRead_ChunkedEncoding() 167var response = await _mediumLogRequestChunked.SendAsync(Request, HttpCompletionOption.ResponseHeadersRead, CancellationToken.None) 175public async Task<HttpResponseMessage> Medium_Log_Request_ContentRead_ChunkedEncoding() 177var response = await _mediumLogRequestChunked.SendAsync(Request, HttpCompletionOption.ResponseContentRead, CancellationToken.None) 185public async Task<HttpResponseMessage> Medium_Log_Response_HeadersRead_ChunkedEncoding() 187var response = await _mediumLogResponseChunked.SendAsync(Request, HttpCompletionOption.ResponseHeadersRead, CancellationToken.None) 195public async Task<HttpResponseMessage> Medium_Log_Response_ContentRead_ChunkedEncoding() 197var response = await _mediumLogResponseChunked.SendAsync(Request, HttpCompletionOption.ResponseContentRead, CancellationToken.None)
Benchmarks\SmallHttpClientLoggingBenchmark.cs (32)
45public async Task<HttpResponseMessage> Small_No_Log_HeadersRead() 47var response = await _smallNoLog.SendAsync(Request, HttpCompletionOption.ResponseHeadersRead, CancellationToken.None) 55public async Task<HttpResponseMessage> Small_No_Log_ContentRead() 57var response = await _smallNoLog.SendAsync(Request, HttpCompletionOption.ResponseContentRead, CancellationToken.None) 65public async Task<HttpResponseMessage> Small_Log_All_HeadersRead() 67var response = await _smallLogAll.SendAsync(Request, HttpCompletionOption.ResponseHeadersRead, CancellationToken.None) 75public async Task<HttpResponseMessage> Small_Log_All_ContentRead() 77var response = await _smallLogAll.SendAsync(Request, HttpCompletionOption.ResponseContentRead, CancellationToken.None) 85public async Task<HttpResponseMessage> Small_Log_Request_HeadersRead() 87var response = await _smallLogRequest.SendAsync(Request, HttpCompletionOption.ResponseHeadersRead, CancellationToken.None) 95public async Task<HttpResponseMessage> Small_Log_Request_ContentRead() 97var response = await _smallLogRequest.SendAsync(Request, HttpCompletionOption.ResponseContentRead, CancellationToken.None) 105public async Task<HttpResponseMessage> Small_Log_Response_HeadersRead() 107var response = await _smallLogResponse.SendAsync(Request, HttpCompletionOption.ResponseHeadersRead, CancellationToken.None) 115public async Task<HttpResponseMessage> Small_Log_Response_ContentRead() 117var response = await _smallLogResponse.SendAsync(Request, HttpCompletionOption.ResponseContentRead, CancellationToken.None) 125public async Task<HttpResponseMessage> Small_No_Log_HeadersRead_ChunkedEncoding() 127var response = await _smallNoLogChunked.SendAsync(Request, HttpCompletionOption.ResponseHeadersRead, CancellationToken.None) 135public async Task<HttpResponseMessage> Small_No_Log_ContentRead_ChunkedEncoding() 137var response = await _smallNoLogChunked.SendAsync(Request, HttpCompletionOption.ResponseContentRead, CancellationToken.None) 145public async Task<HttpResponseMessage> Small_Log_All_HeadersRead_ChunkedEncoding() 147var response = await _smallLogAllChunked.SendAsync(Request, HttpCompletionOption.ResponseHeadersRead, CancellationToken.None) 155public async Task<HttpResponseMessage> Small_Log_All_ContentRead_ChunkedEncoding() 157var response = await _smallLogAllChunked.SendAsync(Request, HttpCompletionOption.ResponseContentRead, CancellationToken.None) 165public async Task<HttpResponseMessage> Small_Log_Request_HeadersRead_ChunkedEncoding() 167var response = await _smallLogRequestChunked.SendAsync(Request, HttpCompletionOption.ResponseHeadersRead, CancellationToken.None) 175public async Task<HttpResponseMessage> Small_Log_Request_ContentRead_ChunkedEncoding() 177var response = await _smallLogRequestChunked.SendAsync(Request, HttpCompletionOption.ResponseContentRead, CancellationToken.None) 185public async Task<HttpResponseMessage> Small_Log_Response_HeadersRead_ChunkedEncoding() 187var response = await _smallLogResponseChunked.SendAsync(Request, HttpCompletionOption.ResponseHeadersRead, CancellationToken.None) 195public async Task<HttpResponseMessage> Small_Log_Response_ContentRead_ChunkedEncoding() 197var response = await _smallLogResponseChunked.SendAsync(Request, HttpCompletionOption.ResponseContentRead, CancellationToken.None)
NoRemoteCallHandler.cs (2)
35protected override Task<HttpResponseMessage> SendAsync(HttpRequestMessage request, CancellationToken cancellationToken) 37var response = new HttpResponseMessage
NoRemoteCallNotSeekableHandler.cs (2)
38protected override Task<HttpResponseMessage> SendAsync(HttpRequestMessage request, CancellationToken cancellationToken) 40var response = new HttpResponseMessage
Microsoft.Extensions.Http.Diagnostics.Tests (70)
Latency\Internal\HttpClientLatencyLogEnricherTest.cs (2)
46using HttpResponseMessage httpResponseMessage = new(); 66using HttpResponseMessage httpResponseMessage = new();
Latency\Internal\HttpLatencyTelemetryHandlerTest.cs (2)
64var resp = new Mock<HttpResponseMessage>(); 66mockHandler.Protected().Setup<Task<HttpResponseMessage>>(
Logging\AcceptanceTests.cs (7)
40using var _ = await httpClient.GetAsync(_unreachableRequestUri); 71using var _ = await httpClient.GetAsync(_unreachableRequestUri); 197using var content = await httpClient 251var content = await firstClient!.SendRequest(httpRequestMessage); 363using var _ = await httpClient.SendAsync(httpRequestMessage); 432using var _ = await httpClient.SendAsync(httpRequestMessage); 690var content = await client.SendAsync(httpRequestMessage, HttpCompletionOption.ResponseHeadersRead);
Logging\HttpClientLoggerTest.cs (21)
55using var httpResponseMessage = new HttpResponseMessage { StatusCode = responseCode }; 193using var httpResponseMessage = new HttpResponseMessage 288using var httpResponseMessage = new HttpResponseMessage 396using var httpResponseMessage = new HttpResponseMessage 493using var httpResponseMessage = new HttpResponseMessage 541It.IsAny<HttpResponseMessage>(), 608using var httpResponseMessage = new HttpResponseMessage 705enricher1.Verify(e => e.Enrich(It.IsAny<IEnrichmentTagCollector>(), It.IsAny<HttpRequestMessage>(), It.IsAny<HttpResponseMessage>(), It.IsAny<Exception>()), Times.Exactly(1)); 706enricher2.Verify(e => e.Enrich(It.IsAny<IEnrichmentTagCollector>(), It.IsAny<HttpRequestMessage>(), It.IsAny<HttpResponseMessage>(), It.IsAny<Exception>()), Times.Exactly(1)); 748enricher1.Verify(e => e.Enrich(It.IsAny<IEnrichmentTagCollector>(), It.IsAny<HttpRequestMessage>(), It.IsAny<HttpResponseMessage>(), It.IsAny<Exception>()), Times.Exactly(1)); 749enricher2.Verify(e => e.Enrich(It.IsAny<IEnrichmentTagCollector>(), It.IsAny<HttpRequestMessage>(), It.IsAny<HttpResponseMessage>(), It.IsAny<Exception>()), Times.Exactly(1)); 758.Setup(e => e.Enrich(It.IsAny<IEnrichmentTagCollector>(), It.IsAny<HttpRequestMessage>(), It.IsAny<HttpResponseMessage>(), It.IsAny<Exception>())) 791enricher1.Verify(e => e.Enrich(It.IsAny<IEnrichmentTagCollector>(), It.IsAny<HttpRequestMessage>(), It.IsAny<HttpResponseMessage>(), It.IsAny<Exception>()), Times.Exactly(1)); 792enricher2.Verify(e => e.Enrich(It.IsAny<IEnrichmentTagCollector>(), It.IsAny<HttpRequestMessage>(), It.IsAny<HttpResponseMessage>(), It.IsAny<Exception>()), Times.Exactly(1)); 801.Setup(e => e.Enrich(It.IsAny<IEnrichmentTagCollector>(), It.IsAny<HttpRequestMessage>(), It.IsAny<HttpResponseMessage>(), It.IsAny<Exception>())) 837enricher1.Verify(e => e.Enrich(It.IsAny<IEnrichmentTagCollector>(), It.IsAny<HttpRequestMessage>(), It.IsAny<HttpResponseMessage>(), It.IsAny<Exception>()), Times.Exactly(1)); 838enricher2.Verify(e => e.Enrich(It.IsAny<IEnrichmentTagCollector>(), It.IsAny<HttpRequestMessage>(), It.IsAny<HttpResponseMessage>(), It.IsAny<Exception>()), Times.Exactly(1)); 879using var httpResponseMessage = new HttpResponseMessage 984.Setup(r => r.ReadResponseAsync(It.IsAny<LogRecord>(), It.IsAny<HttpResponseMessage>(), It.IsAny<List<KeyValuePair<string, string>>?>(), It.IsAny<CancellationToken>())) 991using var httpResponseMessage = new HttpResponseMessage(); 1010using var httpResponseMessage = new HttpResponseMessage();
Logging\HttpClientLoggingExtensionsTest.cs (5)
418var response = new HttpResponseMessage(HttpStatusCode.OK); 429using var response = await client.GetAsync("http://localhost/api"); 496private sealed class TestMessageHandler(Func<HttpRequestMessage, HttpResponseMessage> responseFactory) 499protected override Task<HttpResponseMessage> SendAsync(HttpRequestMessage request, CancellationToken cancellationToken) 509protected override async Task<HttpResponseMessage> SendAsync(HttpRequestMessage request, CancellationToken cancellationToken)
Logging\HttpHeadersReaderTest.cs (4)
24using var httpResponse = new HttpResponseMessage(); 42using var httpResponse = new HttpResponseMessage(); 145using var httpResponse = new HttpResponseMessage { Content = responseContent }; 178using var httpResponse = new HttpResponseMessage();
Logging\HttpRequestReaderTest.cs (7)
93using var httpResponseMessage = new HttpResponseMessage 155using var httpResponseMessage = new HttpResponseMessage 226using var httpResponseMessage = new HttpResponseMessage 302using var httpResponseMessage = new HttpResponseMessage 435using var httpResponseMessage = new HttpResponseMessage 504using var httpResponseMessage = new HttpResponseMessage 574using var httpResponseMessage = new HttpResponseMessage
Logging\HttpResponseBodyReaderTest.cs (9)
48using var httpResponse = new HttpResponseMessage 66using var httpResponse = new HttpResponseMessage 84using var httpResponse = new HttpResponseMessage 109using var httpResponse = new HttpResponseMessage 129using var httpResponse = new HttpResponseMessage 153using var httpResponse = new HttpResponseMessage 180using var httpResponse = new HttpResponseMessage 220using var httpResponse = new HttpResponseMessage 249using var httpResponse = new HttpResponseMessage
Logging\Internal\EmptyEnricher.cs (1)
12public void Enrich(IEnrichmentTagCollector collector, HttpRequestMessage request, HttpResponseMessage? response, Exception? exception)
Logging\Internal\EnricherWithCounter.cs (1)
14public void Enrich(IEnrichmentTagCollector collector, HttpRequestMessage request, HttpResponseMessage? response, Exception? exception)
Logging\Internal\ITestHttpClient1.cs (1)
11Task<HttpResponseMessage> SendRequest(HttpRequestMessage httpRequestMessage);
Logging\Internal\ITestHttpClient2.cs (1)
11Task<HttpResponseMessage> SendRequest(HttpRequestMessage httpRequestMessage);
Logging\Internal\MockedRequestReader.cs (1)
23HttpResponseMessage response,
Logging\Internal\NoRemoteCallHandler.cs (2)
29protected override Task<HttpResponseMessage> SendAsync(HttpRequestMessage request, CancellationToken cancellationToken) 31var response = new HttpResponseMessage
Logging\Internal\TestEnricher.cs (1)
29public void Enrich(IEnrichmentTagCollector tagCollector, HttpRequestMessage request, HttpResponseMessage? response, Exception? exception)
Logging\Internal\TestHttpClient1.cs (1)
18public Task<HttpResponseMessage> SendRequest(HttpRequestMessage httpRequestMessage)
Logging\Internal\TestHttpClient2.cs (1)
18public Task<HttpResponseMessage> SendRequest(HttpRequestMessage httpRequestMessage)
Logging\Internal\TestingHandlerStub.cs (3)
13private readonly Func<HttpRequestMessage, CancellationToken, Task<HttpResponseMessage>> _handlerFunc; 15public TestingHandlerStub(Func<HttpRequestMessage, CancellationToken, Task<HttpResponseMessage>> handlerFunc) 20protected override Task<HttpResponseMessage> SendAsync(HttpRequestMessage request, CancellationToken cancellationToken) => _handlerFunc(request, cancellationToken);
Microsoft.Extensions.Http.Polly (24)
DependencyInjection\PollyHttpClientBuilderExtensions.cs (10)
31public static IHttpClientBuilder AddPolicyHandler(this IHttpClientBuilder builder, IAsyncPolicy<HttpResponseMessage> policy) 63Func<HttpRequestMessage, IAsyncPolicy<HttpResponseMessage>> policySelector) 95Func<IServiceProvider, HttpRequestMessage, IAsyncPolicy<HttpResponseMessage>> policySelector) 144var policy = registry.Get<IAsyncPolicy<HttpResponseMessage>>(policyKey); 167Func<IReadOnlyPolicyRegistry<string>, HttpRequestMessage, IAsyncPolicy<HttpResponseMessage>> policySelector) 212/// <see cref="AddPolicyHandler(IHttpClientBuilder, IAsyncPolicy{HttpResponseMessage})"/> as desired. 217Func<PolicyBuilder<HttpResponseMessage>, IAsyncPolicy<HttpResponseMessage>> configurePolicy) 254public static IHttpClientBuilder AddPolicyHandler(this IHttpClientBuilder builder, Func<IServiceProvider, HttpRequestMessage, string, IAsyncPolicy<HttpResponseMessage>> policyFactory, Func<HttpRequestMessage, string> keySelector) 278if (registry.TryGet<IAsyncPolicy<HttpResponseMessage>>(key, out var policy))
HttpRequestMessageExtensions.cs (2)
25/// The <see cref="PolicyHttpMessageHandler"/> will attach a context to the <see cref="HttpResponseMessage"/> prior 46/// The <see cref="PolicyHttpMessageHandler"/> will attach a context to the <see cref="HttpResponseMessage"/> prior
PolicyHttpMessageHandler.cs (12)
30/// The <see cref="PollyHttpClientBuilderExtensions.AddPolicyHandler(IHttpClientBuilder, IAsyncPolicy{HttpResponseMessage})"/> 47/// The <see cref="PollyHttpClientBuilderExtensions.AddTransientHttpErrorPolicy(IHttpClientBuilder, Func{PolicyBuilder{HttpResponseMessage}, IAsyncPolicy{HttpResponseMessage}})"/> 75private readonly IAsyncPolicy<HttpResponseMessage> _policy; 76private readonly Func<HttpRequestMessage, IAsyncPolicy<HttpResponseMessage>> _policySelector; 82public PolicyHttpMessageHandler(IAsyncPolicy<HttpResponseMessage> policy) 96public PolicyHttpMessageHandler(Func<HttpRequestMessage, IAsyncPolicy<HttpResponseMessage>> policySelector) 107protected override async Task<HttpResponseMessage> SendAsync(HttpRequestMessage request, CancellationToken cancellationToken) 125HttpResponseMessage response; 149protected virtual async Task<HttpResponseMessage> SendCoreAsync(HttpRequestMessage request, Context context, CancellationToken cancellationToken) 168var result = await base.SendAsync(request, cancellationToken).ConfigureAwait(false); 175private IAsyncPolicy<HttpResponseMessage> SelectPolicy(HttpRequestMessage request)
Microsoft.Extensions.Http.Resilience (35)
Hedging\HttpClientHedgingResiliencePredicates.cs (3)
25public static bool IsTransient(Outcome<HttpResponseMessage> outcome) 34/// Determines whether an <see cref="HttpResponseMessage"/> should be treated by hedging as a transient failure. 40public static bool IsTransient(Outcome<HttpResponseMessage> outcome, CancellationToken cancellationToken)
Hedging\HttpHedgingStrategyOptions.cs (2)
13/// Implementation of the <see cref="HedgingStrategyOptions{TResult}"/> class for <see cref="HttpResponseMessage"/> results. 15public class HttpHedgingStrategyOptions : HedgingStrategyOptions<HttpResponseMessage>
Internal\RetryAfterHelper.cs (1)
16internal static bool TryParse(HttpResponseMessage response, TimeProvider timeProvider, out TimeSpan retryAfter)
Polly\HttpCircuitBreakerStrategyOptions.cs (2)
11/// Implementation of the <see cref="CircuitBreakerStrategyOptions{TResult}"/> for <see cref="HttpResponseMessage"/> results. 13public class HttpCircuitBreakerStrategyOptions : CircuitBreakerStrategyOptions<HttpResponseMessage>
Polly\HttpClientResiliencePredicates.cs (5)
25public static bool IsTransient(Outcome<HttpResponseMessage> outcome) => outcome switch 33/// Determines whether an <see cref="HttpResponseMessage"/> should be treated by resilience strategies as a transient failure. 39public static bool IsTransient(Outcome<HttpResponseMessage> outcome, CancellationToken cancellationToken) 53internal static bool IsHttpConnectionTimeout(in Outcome<HttpResponseMessage> outcome, in CancellationToken cancellationToken) 63internal static bool IsTransientHttpFailure(HttpResponseMessage response)
Polly\HttpRetryStrategyOptions.cs (3)
15/// Implementation of the <see cref="RetryStrategyOptions{TResult}"/> for <see cref="HttpResponseMessage"/> results. 17public class HttpRetryStrategyOptions : RetryStrategyOptions<HttpResponseMessage> 57HttpResponseMessage response when RetryAfterHelper.TryParse(response, TimeProvider.System, out var retryAfter) => new ValueTask<TimeSpan?>(retryAfter),
Polly\HttpRetryStrategyOptionsExtensions.cs (1)
64private static HttpRequestMessage? GetRequestMessage(RetryPredicateArguments<HttpResponseMessage> args) =>
Resilience\Internal\HttpResilienceMetricsEnricher.cs (2)
14if (typeof(TResult) != typeof(HttpResponseMessage)) 19if (context.TelemetryEvent.Outcome.HasValue && context.TelemetryEvent.Outcome.Value.Result is HttpResponseMessage response)
Resilience\ResilienceHandler.cs (9)
20private readonly Func<HttpRequestMessage, ResiliencePipeline<HttpResponseMessage>> _pipelineProvider; 27public ResilienceHandler(Func<HttpRequestMessage, ResiliencePipeline<HttpResponseMessage>> pipelineProvider) 37public ResilienceHandler(ResiliencePipeline<HttpResponseMessage> pipeline) 50protected override async Task<HttpResponseMessage> SendAsync(HttpRequestMessage request, CancellationToken cancellationToken) 54ResiliencePipeline<HttpResponseMessage> pipeline = _pipelineProvider(request); 62Outcome<HttpResponseMessage> outcome = await pipeline.ExecuteOutcomeAsync( 74HttpResponseMessage response = await state.instance 82return Outcome.FromException<HttpResponseMessage>(e); 180private Task<HttpResponseMessage> SendCoreAsync(HttpRequestMessage requestMessage, CancellationToken cancellationToken)
Resilience\ResilienceHttpClientBuilderExtensions.Resilience.cs (7)
37Action<ResiliencePipelineBuilder<HttpResponseMessage>> configure) 60Action<ResiliencePipelineBuilder<HttpResponseMessage>, ResilienceHandlerContext> configure) 101private static Func<HttpRequestMessage, ResiliencePipeline<HttpResponseMessage>> CreatePipelineSelector(IServiceProvider serviceProvider, string pipelineName) 108var pipeline = resilienceProvider.GetPipeline<HttpResponseMessage>(new HttpKey(pipelineName, string.Empty)); 118return resilienceProvider.GetPipeline<HttpResponseMessage>(new HttpKey(pipelineName, key)); 136Action<ResiliencePipelineBuilder<HttpResponseMessage>, ResilienceHandlerContext> configure) 141_ = builder.Services.AddResiliencePipeline<HttpKey, HttpResponseMessage>(key, (builder, context) => configure(builder, new ResilienceHandlerContext(context)));
Microsoft.Extensions.Http.Resilience.PerformanceTests (22)
EmptyHandler.cs (1)
12protected override async Task<HttpResponseMessage> SendAsync(HttpRequestMessage request, CancellationToken cancellationToken)
HedgingBenchmark.cs (1)
37public Task<HttpResponseMessage> HedgingCall() => _client.SendAsync(Request, CancellationToken.None);
HttpResilienceBenchmark.cs (5)
46public Task<HttpResponseMessage> DefaultClient() 52public Task<HttpResponseMessage> SingleHandler() 58public Task<HttpResponseMessage> StandardResilienceHandler() 64public Task<HttpResponseMessage> StandardHedgingHandler_RoutesFromRequest() 70public Task<HttpResponseMessage> StandardHedgingHandler_RoutesFromConfig()
NoRemoteCallHandler.cs (4)
12private readonly HttpResponseMessage _response; 13private readonly Task<HttpResponseMessage> _completedResponse; 26protected override Task<HttpResponseMessage> SendAsync(HttpRequestMessage request, CancellationToken cancellationToken) 33protected override HttpResponseMessage Send(HttpRequestMessage request, CancellationToken cancellationToken)
RetryBenchmark.cs (4)
48var builder = Policy.Handle<HttpRequestException>().Or<TimeoutRejectedException>().OrResult<HttpResponseMessage>(r => 69public Task<HttpResponseMessage> Retry_Polly_V7() 75public Task<HttpResponseMessage> Retry_Polly_V8() 81public HttpResponseMessage Retry_Polly_V8_Sync()
StandardResilienceBenchmark.cs (7)
43var builder = Policy.Handle<HttpRequestException>().Or<TimeoutRejectedException>().OrResult<HttpResponseMessage>(r => 53Policy.TimeoutAsync<HttpResponseMessage>(3), 56Policy.BulkheadAsync<HttpResponseMessage>(1000, 100), 57Policy.TimeoutAsync<HttpResponseMessage>(30)); 71public Task<HttpResponseMessage> StandardPipeline_Polly_V7() 77public Task<HttpResponseMessage> StandardPipeline_Polly_V8() 83public HttpResponseMessage StandardPipeline_Polly_V8_Sync()
Microsoft.Extensions.Http.Resilience.Tests (90)
Hedging\HedgingTests.cs (11)
37private readonly Queue<HttpResponseMessage> _responses = new(); 68foreach (var response in _responses) 107using var _ = await SendRequest(client, request, asynchronous, _cancellationTokenSource.Token); 127using var _ = await SendRequest(client, request, asynchronous, _cancellationTokenSource.Token); 200using var result = await SendRequest(client, request, asynchronous, _cancellationTokenSource.Token); 224using var _ = await SendRequest(client, request, asynchronous, _cancellationTokenSource.Token); 250using var _ = await SendRequest(client, request, asynchronous, _cancellationTokenSource.Token); 277using var _ = await SendRequest(client, request, asynchronous, _cancellationTokenSource.Token); 300using var result = await SendRequest(client, request, asynchronous, _cancellationTokenSource.Token); 308protected static Task<HttpResponseMessage> SendRequest( 348private Task<HttpResponseMessage> InnerHandlerFunction(HttpRequestMessage request, CancellationToken cancellationToken)
Hedging\HttpClientHedgingResiliencePredicatesTests.cs (6)
29Assert.True(HttpClientHedgingResiliencePredicates.IsTransient(Outcome.FromException<HttpResponseMessage>(new TimeoutRejectedException()))); 30Assert.True(HttpClientHedgingResiliencePredicates.IsTransient(Outcome.FromException<HttpResponseMessage>(new BrokenCircuitException()))); 31Assert.True(HttpClientHedgingResiliencePredicates.IsTransient(Outcome.FromException<HttpResponseMessage>(new HttpRequestException()))); 32Assert.False(HttpClientHedgingResiliencePredicates.IsTransient(Outcome.FromException<HttpResponseMessage>(new InvalidOperationException()))); 33Assert.False(HttpClientHedgingResiliencePredicates.IsTransient(Outcome.FromResult<HttpResponseMessage>(null))); 42using var response = new HttpResponseMessage(code);
Hedging\StandardHedgingTests.cs (13)
116using var response = new HttpResponseMessage(HttpStatusCode.OK); 118var args = new HedgingActionGeneratorArguments<HttpResponseMessage>(primary, secondary, 0, _ => Outcome.FromResultAsValueTask(response)); 177var primary = pipelineProvider.GetPipeline<HttpResponseMessage>(new HttpKey("clientId-standard-hedging", "instance")).GetPipelineDescriptor(); 186var inner = pipelineProvider.GetPipeline<HttpResponseMessage>(new HttpKey("clientId-standard-hedging-endpoint", "instance")).GetPipelineDescriptor(); 206var noPolicy = ResiliencePipeline<HttpResponseMessage>.Empty; 219provider.Setup(v => v.GetPipeline<HttpResponseMessage>(new HttpKey("clientId-standard-hedging", string.Empty))).Returns(noPolicy); 220provider.Setup(v => v.GetPipeline<HttpResponseMessage>(new HttpKey("clientId-standard-hedging-endpoint", customKey))).Returns(noPolicy); 226using var response = await SendRequest(client, request, asynchronous); 257using var _ = await SendRequest(client, firstRequest, asynchronous); 264using var __ = await SendRequest(client, secondRequest, asynchronous); 292using var _ = await SendRequest(client, request, asynchronous); 342using var _ = await SendRequest(client, request, asynchronous); 352protected override async Task<HttpResponseMessage> SendAsync(HttpRequestMessage request, CancellationToken cancellationToken)
Helpers\TestHandlerStub.cs (3)
14private readonly Func<HttpRequestMessage, CancellationToken, Task<HttpResponseMessage>> _handlerFunc; 21public TestHandlerStub(Func<HttpRequestMessage, CancellationToken, Task<HttpResponseMessage>> handlerFunc) 26protected override Task<HttpResponseMessage> SendAsync(HttpRequestMessage request, CancellationToken cancellationToken)
Internal\RequestMessageSnapshotStrategyTests.cs (1)
29return new ValueTask<HttpResponseMessage>(new HttpResponseMessage());
Internal\RetryAfterHelperTests.cs (4)
19using var response = new HttpResponseMessage(); 31using var response = new HttpResponseMessage(); 44using var response = new HttpResponseMessage(); 58using var response = new HttpResponseMessage();
Polly\HttpCircuitBreakerStrategyOptionsTests.cs (5)
59using var response = new HttpResponseMessage { StatusCode = statusCode }; 72private CircuitBreakerPredicateArguments<HttpResponseMessage> CreateArgs(Exception error) 73=> new(_context, Outcome.FromException<HttpResponseMessage>(error)); 75private CircuitBreakerPredicateArguments<HttpResponseMessage> CreateArgs(HttpResponseMessage response)
Polly\HttpClientResiliencePredicatesTests.cs (2)
39isTransientHttpException = HttpClientResiliencePredicates.IsTransient(Outcome.FromException<HttpResponseMessage>(ex)); 55var response = new HttpResponseMessage { StatusCode = statusCode };
Polly\HttpRetryStrategyOptionsExtensionsTests.cs (7)
50using var response = new HttpResponseMessage { RequestMessage = request }; 62using var response = new HttpResponseMessage { RequestMessage = request }; 86using var response = new HttpResponseMessage { RequestMessage = null }; 109using var response = new HttpResponseMessage { RequestMessage = request }; 114private static RetryPredicateArguments<HttpResponseMessage> CreatePredicateArguments(HttpResponseMessage? response, ResilienceContext? context = null) 116return new RetryPredicateArguments<HttpResponseMessage>(
Polly\HttpRetryStrategyOptionsTests.cs (10)
58var response = new HttpResponseMessage { StatusCode = statusCode }; 69var args = CreateArgs(Outcome.FromException<HttpResponseMessage>(exception), token ?? default); 83var response = new HttpResponseMessage { StatusCode = statusCode }; 93var args = CreateArgs(Outcome.FromException<HttpResponseMessage>(exception), token ?? default); 102using var responseMessage = new HttpResponseMessage(); 115Outcome.FromResult<HttpResponseMessage>(null), 121Outcome.FromException<HttpResponseMessage>(new InvalidOperationException()), 130using var responseMessage = new HttpResponseMessage 159private static RetryPredicateArguments<HttpResponseMessage> CreateArgs( 160Outcome<HttpResponseMessage> outcome,
Resilience\HttpClientBuilderExtensionsTests.BySelector.cs (2)
132.Setup(p => p.GetPipeline<HttpResponseMessage>(new HttpKey(pipelineName, expectedPipelineKey))) 133.Returns(ResiliencePipeline<HttpResponseMessage>.Empty);
Resilience\HttpClientBuilderExtensionsTests.Resilience.cs (10)
36Assert.Throws<ArgumentNullException>(() => builder.AddResilienceHandler("dummy", (Action<ResiliencePipelineBuilder<HttpResponseMessage>>)null!)); 37Assert.Throws<ArgumentNullException>(() => builder.AddResilienceHandler("dummy", (Action<ResiliencePipelineBuilder<HttpResponseMessage>, ResilienceHandlerContext>)null!)); 135using var response = await SendRequest(client, "https://dummy", asynchronous); 220.Setup(v => v.GetPipeline<HttpResponseMessage>(new HttpKey(expectedPipelineKey, "https://dummy1"))) 221.Returns(ResiliencePipeline<HttpResponseMessage>.Empty); 226.Setup(v => v.GetPipeline<HttpResponseMessage>(new HttpKey(expectedPipelineKey, string.Empty))) 227.Returns(ResiliencePipeline<HttpResponseMessage>.Empty); 260.Setup(v => v.GetPipeline<HttpResponseMessage>(new HttpKey(pipelineName, string.Empty))) 261.Returns(ResiliencePipeline<HttpResponseMessage>.Empty) 361private void ConfigureBuilder(ResiliencePipelineBuilder<HttpResponseMessage> builder) => builder.AddTimeout(TimeSpan.FromSeconds(1));
Resilience\HttpClientBuilderExtensionsTests.Standard.cs (4)
39private static Task<HttpResponseMessage> SendRequest(HttpClient client, string url, bool asynchronous) 165var descriptor = provider.GetPipeline<HttpResponseMessage>(new HttpKey("test-standard", string.Empty)).GetPipelineDescriptor(); 295private static ResiliencePipeline<HttpResponseMessage> GetPipeline(IServiceCollection services, string name) 299return provider.GetPipeline<HttpResponseMessage>(new HttpKey(name, string.Empty));
Resilience\HttpResilienceMetricsEnricherTests.cs (4)
34var context = new EnrichmentContext<HttpResponseMessage, string>(default, tags); 46using var response = new HttpResponseMessage(System.Net.HttpStatusCode.InternalServerError); 47var args = new TelemetryEventArguments<HttpResponseMessage, string>(default!, default!, default!, default!, Outcome.FromResult(response)); 48var context = new EnrichmentContext<HttpResponseMessage, string>(args, tags);
Resilience\ResilienceHandlerTest.cs (8)
28using var handler = new ResilienceHandler(ResiliencePipeline<HttpResponseMessage>.Empty); 66using var handler = new ResilienceHandler(_ => ResiliencePipeline<HttpResponseMessage>.Empty); 98using var handler = new ResilienceHandler(_ => ResiliencePipeline<HttpResponseMessage>.Empty); 115var response = await InvokeHandler(invoker, request, asynchronous); 129using var handler = new ResilienceHandler(_ => ResiliencePipeline<HttpResponseMessage>.Empty); 140var response = await InvokeHandler(invoker, request, asynchronous, source.Token); 153using var handler = new ResilienceHandler(_ => ResiliencePipeline<HttpResponseMessage>.Empty); 162private static Task<HttpResponseMessage> InvokeHandler(
Microsoft.Extensions.Logging.AzureAppServices (2)
BlobAppendReferenceWrapper.cs (2)
33Task<HttpResponseMessage> AppendDataAsync() 44var response = await AppendDataAsync().ConfigureAwait(false);
Microsoft.Extensions.ML (2)
ModelLoaders\UriModelLoader.cs (2)
110var resp = await client.SendAsync(headRequest); 143var resp = await client.GetAsync(_uri);
Microsoft.Extensions.ServiceDiscovery (2)
Http\ResolvingHttpClientHandler.cs (1)
17protected override async Task<HttpResponseMessage> SendAsync(HttpRequestMessage request, CancellationToken cancellationToken)
Http\ResolvingHttpDelegatingHandler.cs (1)
41protected override async Task<HttpResponseMessage> SendAsync(HttpRequestMessage request, CancellationToken cancellationToken)
Microsoft.Maui.Controls (1)
StreamWrapper.cs (1)
95 var response = await client.GetAsync(uri, cancellationToken).ConfigureAwait(false);
Microsoft.ML.AutoML.Tests (1)
DatasetUtil.cs (1)
210var response = await client.GetAsync(url).ConfigureAwait(false);
Microsoft.ML.Core (1)
Utilities\ResourceManagerUtils.cs (1)
268var response = await httpClient.GetAsync(uri, ct).ConfigureAwait(false);
Microsoft.ML.PerformanceTests (3)
ImageClassificationBench.cs (3)
163var headerResponse = client.GetAsync(url, HttpCompletionOption.ResponseHeadersRead).Result; 171var response = client.GetAsync(url).Result; 180var response = client.GetAsync(url).Result;
Microsoft.ML.Tokenizers (1)
Utils\Helpers.netcoreapp.cs (1)
31HttpResponseMessage response = client.Send(new HttpRequestMessage(HttpMethod.Get, url), HttpCompletionOption.ResponseHeadersRead);
Microsoft.ML.Tokenizers.Data.Tests (1)
test\Microsoft.ML.Tokenizers.Tests\Utils.cs (1)
21var response = await client.GetAsync(url);
Microsoft.ML.Tokenizers.Tests (2)
src\Microsoft.ML.Tokenizers\Utils\Helpers.netcoreapp.cs (1)
31HttpResponseMessage response = client.Send(new HttpRequestMessage(HttpMethod.Get, url), HttpCompletionOption.ResponseHeadersRead);
Utils.cs (1)
21var response = await client.GetAsync(url);
Microsoft.NET.Build.Containers (32)
AmazonECRMessageHandler.cs (1)
20protected override async Task<HttpResponseMessage> SendAsync(HttpRequestMessage request, CancellationToken cancellationToken)
AuthHandshakeMessageHandler.cs (5)
74private static bool TryParseAuthenticationInfo(HttpResponseMessage msg, [NotNullWhen(true)] out string? scheme, out AuthInfo? bearerAuthInfo) 488using HttpResponseMessage postResponse = await base.SendAsync(postMessage, cancellationToken).ConfigureAwait(false); 532using var tokenResponse = await base.SendAsync(message, cancellationToken).ConfigureAwait(false); 572protected override async Task<HttpResponseMessage> SendAsync(HttpRequestMessage request, CancellationToken cancellationToken) 591var response = await base.SendAsync(request, cancellationToken).ConfigureAwait(false);
FallbackToHttpMessageHandler.cs (2)
30protected override async Task<HttpResponseMessage> SendAsync(HttpRequestMessage request, CancellationToken cancellationToken) 58HttpResponseMessage response = await base.SendAsync(request, cancellationToken).ConfigureAwait(false);
Registry\DefaultBlobOperations.cs (7)
33using HttpResponseMessage response = await _client.SendAsync(new HttpRequestMessage(HttpMethod.Head, new Uri(_baseUri, $"/v2/{repositoryName}/blobs/{digest}")), cancellationToken).ConfigureAwait(false); 46HttpResponseMessage response = await GetAsync(repositoryName, digest, cancellationToken).ConfigureAwait(false); 57HttpResponseMessage response = await GetAsync(repositoryName, digest, cancellationToken).ConfigureAwait(false); 62private async Task<HttpResponseMessage> GetAsync(string repositoryName, string digest, CancellationToken cancellationToken) 66HttpResponseMessage response = await _client.SendAsync(request, HttpCompletionOption.ResponseHeadersRead, cancellationToken).ConfigureAwait(false); 71_ => await LogAndThrowContainerHttpException<HttpResponseMessage>(response, cancellationToken).ConfigureAwait(false) 75private async Task<T> LogAndThrowContainerHttpException<T>(HttpResponseMessage response, CancellationToken cancellationToken)
Registry\DefaultBlobUploadOperations.cs (5)
31HttpResponseMessage finalizeResponse = await _client.PutAsync(putUri, null, cancellationToken).ConfigureAwait(false); 43public async Task<HttpResponseMessage> GetStatusAsync(Uri uploadUri, CancellationToken cancellationToken) 53HttpResponseMessage pushResponse = await _client.PostAsync(startUploadUri, content: null, cancellationToken).ConfigureAwait(false); 69HttpResponseMessage pushResponse = await _client.PostAsync(new Uri(_baseUri, $"/v2/{destinationRepository}/blobs/uploads/?mount={digest}&from={sourceRepository}"), content: null, cancellationToken).ConfigureAwait(false); 110using HttpResponseMessage patchResponse = await _client.SendAsync(patchMessage, cancellationToken).ConfigureAwait(false);
Registry\DefaultManifestOperations.cs (5)
27public async Task<HttpResponseMessage> GetAsync(string repositoryName, string reference, CancellationToken cancellationToken) 31HttpResponseMessage response = await _client.SendAsync(request, cancellationToken).ConfigureAwait(false); 37_ => await LogAndThrowContainerHttpException<HttpResponseMessage>(response, cancellationToken).ConfigureAwait(false) 46HttpResponseMessage putResponse = await _client.PutAsync(new Uri(_baseUri, $"/v2/{repositoryName}/manifests/{reference}"), manifestUploadContent, cancellationToken).ConfigureAwait(false); 55private async Task<T> LogAndThrowContainerHttpException<T>(HttpResponseMessage response, CancellationToken cancellationToken)
Registry\HttpExtensions.cs (2)
31public static Uri GetNextLocation(this HttpResponseMessage response) 67internal static async Task LogHttpResponseAsync(this HttpResponseMessage response, ILogger logger, CancellationToken cancellationToken)
Registry\IBlobUploadOperations.cs (1)
22public Task<HttpResponseMessage> GetStatusAsync(Uri uploadUri, CancellationToken cancellationToken);
Registry\IManifestOperations.cs (1)
14public Task<HttpResponseMessage> GetAsync(string repositoryName, string reference, CancellationToken cancellationToken);
Registry\Registry.cs (3)
193using HttpResponseMessage initialManifestResponse = await _registryAPI.Manifest.GetAsync(repositoryName, reference, cancellationToken).ConfigureAwait(false); 241using HttpResponseMessage initialManifestResponse = await _registryAPI.Manifest.GetAsync(repositoryName, reference, cancellationToken).ConfigureAwait(false); 389using HttpResponseMessage manifestResponse = await _registryAPI.Manifest.GetAsync(repositoryName, manifestDigest, cancellationToken).ConfigureAwait(false);
Microsoft.NET.Sdk.Publish.Tasks (13)
Kudu\KuduVfsDeploy.cs (1)
72using (var response = await client.SendAsync(req))
Kudu\KuduZipDeploy.cs (1)
63using (var response = await client.SendAsync(req))
Tasks\Http\DefaultHttpClient.cs (3)
20public Task<HttpResponseMessage> PostAsync(Uri uri, StreamContent content) 26public Task<HttpResponseMessage> GetAsync(Uri uri, CancellationToken cancellationToken) 32public Task<HttpResponseMessage> PutAsync(Uri uri, StreamContent content, CancellationToken cancellationToken)
Tasks\Http\HttpClientExtensions.cs (3)
72HttpResponseMessage responseMessage = await client.PostAsync(uri, content); 130HttpResponseMessage responseMessage = await client.PutAsync(uri, content, cancellationToken); 166HttpResponseMessage responseMessage = await client.GetAsync(uri, cancellationToken);
Tasks\Http\HttpResponseMessageWrapper.cs (2)
11private readonly HttpResponseMessage _message; 14public HttpResponseMessageWrapper(HttpResponseMessage message)
Tasks\Http\IHttpClient.cs (3)
25Task<HttpResponseMessage> PostAsync(Uri uri, StreamContent content); 33Task<HttpResponseMessage> GetAsync(Uri uri, CancellationToken cancellationToken); 42Task<HttpResponseMessage> PutAsync(Uri uri, StreamContent content, CancellationToken cancellationToken);
Microsoft.TemplateSearch.Common (2)
Providers\NuGetMetadataSearchProvider.cs (2)
185using HttpResponseMessage response = await client.GetAsync(searchMetadataUri, cancellationToken).ConfigureAwait(false); 236private string GetResponseDetails(HttpResponseMessage response)
netstandard (1)
netstandard.cs (1)
1132[assembly: System.Runtime.CompilerServices.TypeForwardedTo(typeof(System.Net.Http.HttpResponseMessage))]
NuGet.Packaging (1)
Signing\Timestamp\Rfc3161TimestampRequestNetstandard21Wrapper.cs (1)
59using (HttpResponseMessage httpResponse = await HttpClient.PostAsync(timestampUri, content))
NuGet.Protocol (30)
HttpResponseMessageExtensions.cs (1)
12public static void LogServerWarning(this HttpResponseMessage response, ILogger log)
HttpSource\DownloadTimeoutStreamContent.cs (1)
12/// to the contained stream. When the <see cref="HttpResponseMessage"/> is disposed, this
HttpSource\HttpCacheUtility.cs (1)
53HttpResponseMessage response,
HttpSource\HttpRetryHandler.cs (4)
41public Task<HttpResponseMessage> SendAsync( 57public async Task<HttpResponseMessage> SendAsync( 75HttpResponseMessage? response = null; 157var responseMessage = await request.HttpClient.SendAsync(requestMessage, request.CompletionOption, timeoutToken);
HttpSource\HttpSource.cs (6)
220Func<HttpResponseMessage?, Task<T>> processAsync, 275Func<HttpResponseMessage, Task<T>> processAsync, 284Func<HttpResponseMessage, Task<T>> processAsync, 354HttpResponseMessage response; 490public ThrottledResponse(IThrottle throttle, HttpResponseMessage response) 506public HttpResponseMessage Response { get; }
HttpSource\HttpSourceAuthenticationHandler.cs (2)
68protected override async Task<HttpResponseMessage> SendAsync(HttpRequestMessage request, CancellationToken cancellationToken) 75HttpResponseMessage? response = null;
HttpSource\HttpSourceCachedRequest.cs (2)
63/// When processing the <see cref="HttpResponseMessage"/>, this flag allows 79/// The timeout to use when fetching the <see cref="HttpResponseMessage"/>. Since
HttpSource\HttpSourceRequest.cs (2)
43/// When processing the <see cref="HttpResponseMessage"/>, this flag allows 50/// The timeout to use when fetching the <see cref="HttpResponseMessage"/>. Since
HttpSource\IHttpRetryHandler.cs (2)
13Task<HttpResponseMessage> SendAsync( 18Task<HttpResponseMessage> SendAsync(
HttpSource\ProxyAuthenticationHandler.cs (2)
57protected override async Task<HttpResponseMessage> SendAsync(HttpRequestMessage request, 60HttpResponseMessage? response = null;
HttpSource\ServerWarningLogHandler.cs (2)
19protected override async Task<HttpResponseMessage> SendAsync(HttpRequestMessage request, CancellationToken cancellationToken) 23var response = await base.SendAsync(request, cancellationToken);
Resources\PackageSearchResourceV3.cs (4)
223internal async Task<IReadOnlyList<PackageSearchMetadata>> ProcessHttpStreamTakeCountedItemAsync(HttpResponseMessage? httpInitialResponse, int take, CancellationToken token) 234private async Task<V3SearchResults?> ProcessHttpStreamWithoutBufferingAsync(HttpResponseMessage? httpInitialResponse, uint take, CancellationToken token) 255private static async Task<V3SearchResults?> ProcessHttpStreamWithStjAsync(HttpResponseMessage httpInitialResponse, uint take, CancellationToken token) 272private static async Task<V3SearchResults?> ProcessHttpStreamWithNsjAsync(HttpResponseMessage httpInitialResponse, uint take, CancellationToken token)
Resources\PackageUpdateResource.cs (1)
534private static HttpStatusCode? EnsureSuccessStatusCode(HttpResponseMessage response, HttpStatusCode? codeNotToThrow, ILogger logger)
Pipelines.Library (1)
DistributedApplicationPipelineExtensions.cs (1)
156var response = await httpClient.PostAsync(kuduUrl, content, cancellationToken).ConfigureAwait(false);
Stress.ApiService (1)
Program.cs (1)
157var response = await client.GetAsync(url);
System.Net.Http (162)
System\Net\Http\DelegatingHandler.cs (2)
45protected internal override HttpResponseMessage Send(HttpRequestMessage request, CancellationToken cancellationToken) 53protected internal override Task<HttpResponseMessage> SendAsync(HttpRequestMessage request, CancellationToken cancellationToken)
System\Net\Http\DiagnosticsHandler.cs (11)
76internal override ValueTask<HttpResponseMessage> SendAsync(HttpRequestMessage request, bool async, CancellationToken cancellationToken) 85new ValueTask<HttpResponseMessage>(_innerHandler.SendAsync(request, cancellationToken)) : 86new ValueTask<HttpResponseMessage>(_innerHandler.Send(request, cancellationToken)); 90private async ValueTask<HttpResponseMessage> SendAsyncCore(HttpRequestMessage request, bool async, CancellationToken cancellationToken) 160HttpResponseMessage? response = null; 280internal ActivityStopData(HttpResponseMessage? response, HttpRequestMessage request, TaskStatus requestTaskStatus) 287public HttpResponseMessage? Response { get; } 338[DynamicDependency(nameof(HttpResponseMessage.StatusCode), typeof(HttpResponseMessage))] 339internal ResponseData(HttpResponseMessage? response, Guid loggingRequestId, long timestamp, TaskStatus requestTaskStatus) 347public HttpResponseMessage? Response { get; }
System\Net\Http\DiagnosticsHelper.cs (1)
53public static bool TryGetErrorType(HttpResponseMessage? response, Exception? exception, out string? errorType)
System\Net\Http\HttpClient.cs (41)
189HttpResponseMessage? response = null; 263HttpResponseMessage? response = null; 339HttpResponseMessage? response = null; 365public Task<HttpResponseMessage> GetAsync([StringSyntax(StringSyntaxAttribute.Uri)] string? requestUri) => 368public Task<HttpResponseMessage> GetAsync(Uri? requestUri) => 371public Task<HttpResponseMessage> GetAsync([StringSyntax(StringSyntaxAttribute.Uri)] string? requestUri, HttpCompletionOption completionOption) => 374public Task<HttpResponseMessage> GetAsync(Uri? requestUri, HttpCompletionOption completionOption) => 377public Task<HttpResponseMessage> GetAsync([StringSyntax(StringSyntaxAttribute.Uri)] string? requestUri, CancellationToken cancellationToken) => 380public Task<HttpResponseMessage> GetAsync(Uri? requestUri, CancellationToken cancellationToken) => 383public Task<HttpResponseMessage> GetAsync([StringSyntax(StringSyntaxAttribute.Uri)] string? requestUri, HttpCompletionOption completionOption, CancellationToken cancellationToken) => 386public Task<HttpResponseMessage> GetAsync(Uri? requestUri, HttpCompletionOption completionOption, CancellationToken cancellationToken) => 389public Task<HttpResponseMessage> PostAsync([StringSyntax(StringSyntaxAttribute.Uri)] string? requestUri, HttpContent? content) => 392public Task<HttpResponseMessage> PostAsync(Uri? requestUri, HttpContent? content) => 395public Task<HttpResponseMessage> PostAsync([StringSyntax(StringSyntaxAttribute.Uri)] string? requestUri, HttpContent? content, CancellationToken cancellationToken) => 398public Task<HttpResponseMessage> PostAsync(Uri? requestUri, HttpContent? content, CancellationToken cancellationToken) 405public Task<HttpResponseMessage> PutAsync([StringSyntax(StringSyntaxAttribute.Uri)] string? requestUri, HttpContent? content) => 408public Task<HttpResponseMessage> PutAsync(Uri? requestUri, HttpContent? content) => 411public Task<HttpResponseMessage> PutAsync([StringSyntax(StringSyntaxAttribute.Uri)] string? requestUri, HttpContent? content, CancellationToken cancellationToken) => 414public Task<HttpResponseMessage> PutAsync(Uri? requestUri, HttpContent? content, CancellationToken cancellationToken) 421public Task<HttpResponseMessage> PatchAsync([StringSyntax(StringSyntaxAttribute.Uri)] string? requestUri, HttpContent? content) => 424public Task<HttpResponseMessage> PatchAsync(Uri? requestUri, HttpContent? content) => 427public Task<HttpResponseMessage> PatchAsync([StringSyntax(StringSyntaxAttribute.Uri)] string? requestUri, HttpContent? content, CancellationToken cancellationToken) => 430public Task<HttpResponseMessage> PatchAsync(Uri? requestUri, HttpContent? content, CancellationToken cancellationToken) 437public Task<HttpResponseMessage> DeleteAsync([StringSyntax(StringSyntaxAttribute.Uri)] string? requestUri) => 440public Task<HttpResponseMessage> DeleteAsync(Uri? requestUri) => 443public Task<HttpResponseMessage> DeleteAsync([StringSyntax(StringSyntaxAttribute.Uri)] string? requestUri, CancellationToken cancellationToken) => 446public Task<HttpResponseMessage> DeleteAsync(Uri? requestUri, CancellationToken cancellationToken) => 457public HttpResponseMessage Send(HttpRequestMessage request) => 464public HttpResponseMessage Send(HttpRequestMessage request, HttpCompletionOption completionOption) => 471public override HttpResponseMessage Send(HttpRequestMessage request, CancellationToken cancellationToken) => 478public HttpResponseMessage Send(HttpRequestMessage request, HttpCompletionOption completionOption, CancellationToken cancellationToken) 485HttpResponseMessage? response = null; 517public Task<HttpResponseMessage> SendAsync(HttpRequestMessage request) => 520public override Task<HttpResponseMessage> SendAsync(HttpRequestMessage request, CancellationToken cancellationToken) => 523public Task<HttpResponseMessage> SendAsync(HttpRequestMessage request, HttpCompletionOption completionOption) => 526public Task<HttpResponseMessage> SendAsync(HttpRequestMessage request, HttpCompletionOption completionOption, CancellationToken cancellationToken) 534async Task<HttpResponseMessage> Core( 540HttpResponseMessage? response = null; 586private static void ThrowForNullResponse([NotNull] HttpResponseMessage? response) 598private void HandleFailure(Exception e, bool telemetryStarted, HttpResponseMessage? response, CancellationTokenSource cts, CancellationToken cancellationToken, CancellationTokenSource pendingRequestsCts) 659private static void FinishSend(HttpResponseMessage? response, CancellationTokenSource cts, bool disposeCts, bool telemetryStarted, bool responseContentTelemetryStarted)
System\Net\Http\HttpClientHandler.cs (2)
358protected internal override HttpResponseMessage Send(HttpRequestMessage request, CancellationToken cancellationToken) 368protected internal override Task<HttpResponseMessage> SendAsync(HttpRequestMessage request, CancellationToken cancellationToken)
System\Net\Http\HttpMessageHandler.cs (2)
22protected internal virtual HttpResponseMessage Send(HttpRequestMessage request, CancellationToken cancellationToken) 27protected internal abstract Task<HttpResponseMessage> SendAsync(HttpRequestMessage request, CancellationToken cancellationToken);
System\Net\Http\HttpMessageInvoker.cs (5)
35public virtual HttpResponseMessage Send(HttpRequestMessage request, CancellationToken cancellationToken) 45HttpResponseMessage? response = null; 67public virtual Task<HttpResponseMessage> SendAsync(HttpRequestMessage request, CancellationToken cancellationToken) 80static async Task<HttpResponseMessage> SendAsyncWithTelemetry(HttpMessageHandler handler, HttpRequestMessage request, CancellationToken cancellationToken) 84HttpResponseMessage? response = null;
System\Net\Http\HttpResponseMessage.cs (1)
161public HttpResponseMessage EnsureSuccessStatusCode()
System\Net\Http\HttpTelemetry.cs (1)
63public void RequestStop(HttpResponseMessage? response)
System\Net\Http\MessageProcessingHandler.cs (10)
27protected abstract HttpResponseMessage ProcessResponse(HttpResponseMessage response, 30protected internal sealed override HttpResponseMessage Send(HttpRequestMessage request, 37HttpResponseMessage response = base.Send(newRequestMessage, cancellationToken); 38HttpResponseMessage newResponseMessage = ProcessResponse(response, cancellationToken); 42protected internal sealed override Task<HttpResponseMessage> SendAsync(HttpRequestMessage request, 56Task<HttpResponseMessage> sendAsyncTask = base.SendAsync(newRequestMessage, cancellationToken); 86HttpResponseMessage responseMessage = self.ProcessResponse(task.Result, token); 118TaskCompletionSource<HttpResponseMessage> tcs, OperationCanceledException e) 136private sealed class SendState : TaskCompletionSource<HttpResponseMessage>
System\Net\Http\Metrics\HttpMetricsEnrichmentContext.cs (3)
26private HttpResponseMessage? _response; 46public HttpResponseMessage? Response => _response; 102HttpResponseMessage? response,
System\Net\Http\Metrics\MetricsHandler.cs (6)
41internal override ValueTask<HttpResponseMessage> SendAsync(HttpRequestMessage request, bool async, CancellationToken cancellationToken) 50new ValueTask<HttpResponseMessage>(_innerHandler.SendAsync(request, cancellationToken)) : 51new ValueTask<HttpResponseMessage>(_innerHandler.Send(request, cancellationToken)); 55private async ValueTask<HttpResponseMessage> SendAsyncWithMetrics(HttpRequestMessage request, bool async, CancellationToken cancellationToken) 60HttpResponseMessage? response = null; 104private void RequestStop(HttpRequestMessage request, HttpResponseMessage? response, Exception? exception, long startTimestamp, bool recordCurrentRequests)
System\Net\Http\SocketsHttpHandler\AuthenticationHelper.cs (10)
61internal static bool IsSessionAuthenticationChallenge(HttpResponseMessage response) 110private static bool TryGetAuthenticationChallenge(HttpResponseMessage response, bool isProxyAuth, Uri authUri, ICredentials credentials, out AuthenticationChallenge challenge) 131private static bool TryGetRepeatedChallenge(HttpResponseMessage response, string scheme, bool isProxyAuth, out string? challengeData) 150private static bool IsAuthenticationChallenge(HttpResponseMessage response, bool isProxyAuth) 157private static HttpHeaderValueCollection<AuthenticationHeaderValue> GetResponseAuthenticationHeaderValues(HttpResponseMessage response, bool isProxyAuth) 206private static ValueTask<HttpResponseMessage> InnerSendAsync(HttpRequestMessage request, bool async, bool isProxyAuth, bool doRequestAuth, HttpConnectionPool pool, CancellationToken cancellationToken) 213private static async ValueTask<HttpResponseMessage> SendWithAuthAsync(HttpRequestMessage request, Uri authUri, bool async, ICredentials credentials, bool preAuthenticate, bool isProxyAuth, bool doRequestAuth, HttpConnectionPool pool, CancellationToken cancellationToken) 256HttpResponseMessage response = await InnerSendAsync(request, async, isProxyAuth, doRequestAuth, pool, cancellationToken).ConfigureAwait(false); 375public static ValueTask<HttpResponseMessage> SendWithProxyAuthAsync(HttpRequestMessage request, Uri proxyUri, bool async, ICredentials proxyCredentials, bool doRequestAuth, HttpConnectionPool pool, CancellationToken cancellationToken) 380public static ValueTask<HttpResponseMessage> SendWithRequestAuthAsync(HttpRequestMessage request, bool async, ICredentials credentials, bool preAuthenticate, HttpConnectionPool pool, CancellationToken cancellationToken)
System\Net\Http\SocketsHttpHandler\AuthenticationHelper.NtAuth.cs (6)
21private static Task<HttpResponseMessage> InnerSendAsync(HttpRequestMessage request, bool async, bool isProxyAuth, HttpConnectionPool pool, HttpConnection connection, CancellationToken cancellationToken) 28private static bool ProxySupportsConnectionAuth(HttpResponseMessage response) 46private static async Task<HttpResponseMessage> SendWithNtAuthAsync(HttpRequestMessage request, Uri authUri, bool async, ICredentials credentials, TokenImpersonationLevel impersonationLevel, bool isProxyAuth, HttpConnection connection, HttpConnectionPool connectionPool, CancellationToken cancellationToken) 48HttpResponseMessage response = await InnerSendAsync(request, async, isProxyAuth, connectionPool, connection, cancellationToken).ConfigureAwait(false); 205public static Task<HttpResponseMessage> SendWithNtProxyAuthAsync(HttpRequestMessage request, Uri proxyUri, bool async, ICredentials proxyCredentials, TokenImpersonationLevel impersonationLevel, HttpConnection connection, HttpConnectionPool connectionPool, CancellationToken cancellationToken) 210public static Task<HttpResponseMessage> SendWithNtConnectionAuthAsync(HttpRequestMessage request, bool async, ICredentials credentials, TokenImpersonationLevel impersonationLevel, HttpConnection connection, HttpConnectionPool connectionPool, CancellationToken cancellationToken)
System\Net\Http\SocketsHttpHandler\ChunkedEncodingReadStream.cs (2)
21private readonly HttpResponseMessage _response; 23public ChunkedEncodingReadStream(HttpConnection connection, HttpResponseMessage response) : base(connection)
System\Net\Http\SocketsHttpHandler\ConnectionPool\HttpConnectionPool.cs (7)
346public ValueTask<HttpResponseMessage> SendAsync(HttpRequestMessage request, bool async, bool doRequestAuth, CancellationToken cancellationToken) 365public ValueTask<HttpResponseMessage> SendWithProxyAuthAsync(HttpRequestMessage request, bool async, bool doRequestAuth, CancellationToken cancellationToken) 375private Task<HttpResponseMessage> SendWithNtConnectionAuthAsync(HttpConnection connection, HttpRequestMessage request, bool async, bool doRequestAuth, CancellationToken cancellationToken) 385public Task<HttpResponseMessage> SendWithNtProxyAuthAsync(HttpConnection connection, HttpRequestMessage request, bool async, CancellationToken cancellationToken) 395public async ValueTask<HttpResponseMessage> SendWithVersionDetectionAndRetryAsync(HttpRequestMessage request, bool async, bool doRequestAuth, CancellationToken cancellationToken) 407HttpResponseMessage? response = null; 789HttpResponseMessage tunnelResponse = await _poolManager.SendProxyConnectAsync(tunnelRequest, _proxyUri!, async, cancellationToken).ConfigureAwait(false);
System\Net\Http\SocketsHttpHandler\ConnectionPool\HttpConnectionPool.Http3.cs (3)
63private async ValueTask<HttpResponseMessage?> TrySendUsingHttp3Async(HttpRequestMessage request, CancellationToken cancellationToken) 107HttpResponseMessage response = await connection.SendAsync(request, waitForConnectionActivity, streamAvailable, cancellationToken).ConfigureAwait(false); 636private void ProcessAltSvc(HttpResponseMessage response)
System\Net\Http\SocketsHttpHandler\CookieHelper.cs (1)
12public static void ProcessReceivedCookies(HttpResponseMessage response, CookieContainer cookieContainer)
System\Net\Http\SocketsHttpHandler\DecompressionHandler.cs (2)
66internal override async ValueTask<HttpResponseMessage> SendAsync(HttpRequestMessage request, bool async, CancellationToken cancellationToken) 98HttpResponseMessage response = await _innerHandler.SendAsync(request, async, cancellationToken).ConfigureAwait(false);
System\Net\Http\SocketsHttpHandler\Http2Connection.cs (2)
2000public async Task<HttpResponseMessage> SendAsync(HttpRequestMessage request, bool async, CancellationToken cancellationToken) 2067HttpResponseMessage response = http2Stream.GetAndClearResponse();
System\Net\Http\SocketsHttpHandler\Http2Stream.cs (9)
35private HttpResponseMessage? _response; 164public HttpResponseMessage GetAndClearResponse() 171HttpResponseMessage r = _response; 1137public int ReadData(Span<byte> buffer, HttpResponseMessage responseMessage) 1162public async ValueTask<int> ReadDataAsync(Memory<byte> buffer, HttpResponseMessage responseMessage, CancellationToken cancellationToken) 1186public void CopyTo(HttpResponseMessage responseMessage, Stream destination, int bufferSize) 1222public async Task CopyToAsync(HttpResponseMessage responseMessage, Stream destination, int bufferSize, CancellationToken cancellationToken) 1258private void MoveTrailersToResponseMessage(HttpResponseMessage responseMessage) 1547private readonly HttpResponseMessage _responseMessage;
System\Net\Http\SocketsHttpHandler\Http3Connection.cs (2)
264public async Task<HttpResponseMessage> SendAsync(HttpRequestMessage request, WaitForHttp3ConnectionActivity waitForConnectionActivity, bool streamAvailable, CancellationToken cancellationToken) 334Task<HttpResponseMessage> responseTask = requestStream.SendAsync(cancellationToken);
System\Net\Http\SocketsHttpHandler\Http3RequestStream.cs (8)
38private HttpResponseMessage? _response; 154public async Task<HttpResponseMessage> SendAsync(CancellationToken cancellationToken) 281HttpResponseMessage response = _response; 652private void CopyTrailersToResponseMessage(HttpResponseMessage responseMessage) 1192private int ReadResponseContent(HttpResponseMessage response, Span<byte> buffer) 1265private async ValueTask<int> ReadResponseContentAsync(HttpResponseMessage response, Memory<byte> buffer, CancellationToken cancellationToken) 1385private async ValueTask<bool> ReadNextDataFrameAsync(HttpResponseMessage response, CancellationToken cancellationToken) 1446private HttpResponseMessage? _response;
System\Net\Http\SocketsHttpHandler\HttpConnection.cs (8)
532public async Task<HttpResponseMessage> SendAsync(HttpRequestMessage request, bool async, CancellationToken cancellationToken) 665var response = new HttpResponseMessage() { RequestMessage = request, Content = new HttpConnectionResponseContent() }; 1029private bool ParseStatusLine(HttpResponseMessage response) 1058private static void ParseStatusLineCore(Span<byte> line, HttpResponseMessage response) 1131private bool ParseHeaders(HttpResponseMessage? response, bool isFromTrailer) 1150private (bool finished, int bytesConsumed) ParseHeadersCore(Span<byte> buffer, HttpResponseMessage? response, bool isFromTrailer) 1229private void AddResponseHeader(ReadOnlySpan<byte> name, ReadOnlySpan<byte> value, HttpResponseMessage response, bool isFromTrailer) 2075public async ValueTask DrainResponseAsync(HttpResponseMessage response, CancellationToken cancellationToken)
System\Net\Http\SocketsHttpHandler\HttpConnectionHandler.cs (1)
20internal override ValueTask<HttpResponseMessage> SendAsync(HttpRequestMessage request, bool async, CancellationToken cancellationToken)
System\Net\Http\SocketsHttpHandler\HttpConnectionPoolManager.cs (4)
332public ValueTask<HttpResponseMessage> SendAsyncCore(HttpRequestMessage request, Uri? proxyUri, bool async, bool doRequestAuth, bool isProxyConnect, CancellationToken cancellationToken) 371public ValueTask<HttpResponseMessage> SendProxyConnectAsync(HttpRequestMessage request, Uri proxyUri, bool async, CancellationToken cancellationToken) 376public ValueTask<HttpResponseMessage> SendAsync(HttpRequestMessage request, bool async, bool doRequestAuth, CancellationToken cancellationToken) 429private async ValueTask<HttpResponseMessage> SendAsyncMultiProxy(HttpRequestMessage request, bool async, bool doRequestAuth, MultiProxy multiProxy, Uri? firstProxy, CancellationToken cancellationToken)
System\Net\Http\SocketsHttpHandler\HttpMessageHandlerStage.cs (4)
11protected internal sealed override HttpResponseMessage Send(HttpRequestMessage request, 14ValueTask<HttpResponseMessage> sendTask = SendAsync(request, async: false, cancellationToken); 20protected internal sealed override Task<HttpResponseMessage> SendAsync(HttpRequestMessage request, CancellationToken cancellationToken) => 23internal abstract ValueTask<HttpResponseMessage> SendAsync(HttpRequestMessage request, bool async, CancellationToken cancellationToken);
System\Net\Http\SocketsHttpHandler\RedirectHandler.cs (3)
27internal override async ValueTask<HttpResponseMessage> SendAsync(HttpRequestMessage request, bool async, CancellationToken cancellationToken) 29HttpResponseMessage response = await _innerHandler.SendAsync(request, async, cancellationToken).ConfigureAwait(false); 93private Uri? GetUriForRedirect(Uri requestUri, HttpResponseMessage response)
System\Net\Http\SocketsHttpHandler\SocketsHttpHandler.cs (5)
574protected internal override HttpResponseMessage Send(HttpRequestMessage request, 605protected internal override Task<HttpResponseMessage> SendAsync(HttpRequestMessage request, CancellationToken cancellationToken) 613return Task.FromCanceled<HttpResponseMessage>(cancellationToken); 619return Task.FromException<HttpResponseMessage>(error); 629async Task<HttpResponseMessage> CreateHandlerAndSendAsync(HttpRequestMessage request, CancellationToken cancellationToken)
System.Net.Http.Json (30)
System\Net\Http\Json\HttpClientJsonExtensions.cs (9)
19private static Task<object?> FromJsonAsyncCore(Func<HttpClient, Uri?, CancellationToken, Task<HttpResponseMessage>> getMethod, HttpClient client, Uri? requestUri, Type type, JsonSerializerOptions? options, CancellationToken cancellationToken = default) => 24private static Task<TValue?> FromJsonAsyncCore<TValue>(Func<HttpClient, Uri?, CancellationToken, Task<HttpResponseMessage>> getMethod, HttpClient client, Uri? requestUri, JsonSerializerOptions? options, CancellationToken cancellationToken = default) => 27private static Task<object?> FromJsonAsyncCore(Func<HttpClient, Uri?, CancellationToken, Task<HttpResponseMessage>> getMethod, HttpClient client, Uri? requestUri, Type type, JsonSerializerContext context, CancellationToken cancellationToken = default) => 30private static Task<TValue?> FromJsonAsyncCore<TValue>(Func<HttpClient, Uri?, CancellationToken, Task<HttpResponseMessage>> getMethod, HttpClient client, Uri? requestUri, JsonTypeInfo<TValue> jsonTypeInfo, CancellationToken cancellationToken) => 34Func<HttpClient, Uri?, CancellationToken, Task<HttpResponseMessage>> getMethod, 54Task<HttpResponseMessage> responseTask; 74Task<HttpResponseMessage> responseTask, 83using HttpResponseMessage response = await responseTask.ConfigureAwait(false); 116HttpResponseMessage response,
System\Net\Http\Json\HttpClientJsonExtensions.Delete.cs (1)
18private static readonly Func<HttpClient, Uri?, CancellationToken, Task<HttpResponseMessage>> s_deleteAsync =
System\Net\Http\Json\HttpClientJsonExtensions.Get.AsyncEnumerable.cs (1)
159using HttpResponseMessage response = await client.GetAsync(requestUri, HttpCompletionOption.ResponseHeadersRead, cancellationToken)
System\Net\Http\Json\HttpClientJsonExtensions.Get.cs (1)
18private static readonly Func<HttpClient, Uri?, CancellationToken, Task<HttpResponseMessage>> s_getAsync =
System\Net\Http\Json\HttpClientJsonExtensions.Patch.cs (6)
27public static Task<HttpResponseMessage> PatchAsJsonAsync<TValue>(this HttpClient client, [StringSyntax(StringSyntaxAttribute.Uri)] string? requestUri, TValue value, JsonSerializerOptions? options = null, CancellationToken cancellationToken = default) 48public static Task<HttpResponseMessage> PatchAsJsonAsync<TValue>(this HttpClient client, Uri? requestUri, TValue value, JsonSerializerOptions? options = null, CancellationToken cancellationToken = default) 68public static Task<HttpResponseMessage> PatchAsJsonAsync<TValue>(this HttpClient client, [StringSyntax(StringSyntaxAttribute.Uri)] string? requestUri, TValue value, CancellationToken cancellationToken) 83public static Task<HttpResponseMessage> PatchAsJsonAsync<TValue>(this HttpClient client, Uri? requestUri, TValue value, CancellationToken cancellationToken) 97public static Task<HttpResponseMessage> PatchAsJsonAsync<TValue>(this HttpClient client, [StringSyntax(StringSyntaxAttribute.Uri)] string? requestUri, TValue value, JsonTypeInfo<TValue> jsonTypeInfo, CancellationToken cancellationToken = default) 116public static Task<HttpResponseMessage> PatchAsJsonAsync<TValue>(this HttpClient client, Uri? requestUri, TValue value, JsonTypeInfo<TValue> jsonTypeInfo, CancellationToken cancellationToken = default)
System\Net\Http\Json\HttpClientJsonExtensions.Post.cs (6)
16public static Task<HttpResponseMessage> PostAsJsonAsync<TValue>(this HttpClient client, [StringSyntax(StringSyntaxAttribute.Uri)] string? requestUri, TValue value, JsonSerializerOptions? options = null, CancellationToken cancellationToken = default) 26public static Task<HttpResponseMessage> PostAsJsonAsync<TValue>(this HttpClient client, Uri? requestUri, TValue value, JsonSerializerOptions? options = null, CancellationToken cancellationToken = default) 36public static Task<HttpResponseMessage> PostAsJsonAsync<TValue>(this HttpClient client, [StringSyntax(StringSyntaxAttribute.Uri)] string? requestUri, TValue value, CancellationToken cancellationToken) 41public static Task<HttpResponseMessage> PostAsJsonAsync<TValue>(this HttpClient client, Uri? requestUri, TValue value, CancellationToken cancellationToken) 44public static Task<HttpResponseMessage> PostAsJsonAsync<TValue>(this HttpClient client, [StringSyntax(StringSyntaxAttribute.Uri)] string? requestUri, TValue value, JsonTypeInfo<TValue> jsonTypeInfo, CancellationToken cancellationToken = default) 52public static Task<HttpResponseMessage> PostAsJsonAsync<TValue>(this HttpClient client, Uri? requestUri, TValue value, JsonTypeInfo<TValue> jsonTypeInfo, CancellationToken cancellationToken = default)
System\Net\Http\Json\HttpClientJsonExtensions.Put.cs (6)
16public static Task<HttpResponseMessage> PutAsJsonAsync<TValue>(this HttpClient client, [StringSyntax(StringSyntaxAttribute.Uri)] string? requestUri, TValue value, JsonSerializerOptions? options = null, CancellationToken cancellationToken = default) 26public static Task<HttpResponseMessage> PutAsJsonAsync<TValue>(this HttpClient client, Uri? requestUri, TValue value, JsonSerializerOptions? options = null, CancellationToken cancellationToken = default) 36public static Task<HttpResponseMessage> PutAsJsonAsync<TValue>(this HttpClient client, [StringSyntax(StringSyntaxAttribute.Uri)] string? requestUri, TValue value, CancellationToken cancellationToken) 41public static Task<HttpResponseMessage> PutAsJsonAsync<TValue>(this HttpClient client, Uri? requestUri, TValue value, CancellationToken cancellationToken) 44public static Task<HttpResponseMessage> PutAsJsonAsync<TValue>(this HttpClient client, [StringSyntax(StringSyntaxAttribute.Uri)] string? requestUri, TValue value, JsonTypeInfo<TValue> jsonTypeInfo, CancellationToken cancellationToken = default) 52public static Task<HttpResponseMessage> PutAsJsonAsync<TValue>(this HttpClient client, Uri? requestUri, TValue value, JsonTypeInfo<TValue> jsonTypeInfo, CancellationToken cancellationToken = default)
System.Net.Http.WinHttpHandler (12)
System\Net\Http\WinHttpHandler.cs (4)
591protected override Task<HttpResponseMessage> SendAsync( 629TaskCompletionSource<HttpResponseMessage> tcs = new TaskCompletionSource<HttpResponseMessage>(); 1006HttpResponseMessage responseMessage = WinHttpResponseParser.CreateResponseMessage(state);
System\Net\Http\WinHttpRequestState.cs (1)
96public TaskCompletionSource<HttpResponseMessage>? Tcs { get; set; }
System\Net\Http\WinHttpResponseParser.cs (4)
18public static HttpResponseMessage CreateResponseMessage(WinHttpRequestState state) 25var response = new HttpResponseMessage(); 278HttpResponseMessage response, 320HttpResponseMessage response,
System\Net\Http\WinHttpResponseStream.cs (2)
21private readonly HttpResponseMessage _responseMessage; 25internal WinHttpResponseStream(SafeWinHttpHandle requestHandle, WinHttpRequestState state, HttpResponseMessage responseMessage)
System\Net\Http\WinHttpTrailersHelper.cs (1)
25public static HttpHeaders GetResponseTrailers(HttpResponseMessage response)
System.Net.Requests (6)
System\Net\HttpWebRequest.cs (3)
48private Task<HttpResponseMessage>? _sendRequestTask; 1194private Task<HttpResponseMessage> SendRequest(bool async, HttpContent? content = null) 1281HttpResponseMessage responseMessage = await _sendRequestTask.ConfigureAwait(false);
System\Net\HttpWebResponse.cs (3)
24private HttpResponseMessage _httpResponseMessage = null!; 58internal HttpWebResponse(HttpResponseMessage _message, Uri requestUri, CookieContainer? cookieContainer) 369var httpResponseMessage = _httpResponseMessage;
System.ServiceModel.Http (12)
System\ServiceModel\Channels\HttpChannelFactory.cs (1)
977private HttpResponseMessage _httpResponseMessage;
System\ServiceModel\Channels\HttpChannelHelpers.cs (2)
103public static HttpResponseMessage ProcessGetResponseWebException(HttpRequestException requestException, HttpRequestMessage request, HttpAbortReason abortReason) 163internal static Exception CreateUnexpectedResponseException(HttpResponseMessage response)
System\ServiceModel\Channels\HttpResponseMessageExtensionMethods.cs (3)
23internal static bool CreateContentIfNull(this HttpResponseMessage httpResponseMessage) 36internal static void MergeWebHeaderCollection(this HttpResponseMessage responseMessage, WebHeaderCollection headersToMerge) 42internal static WebHeaderCollection ToWebHeaderCollection(this HttpResponseMessage httpResponse)
System\ServiceModel\Channels\HttpResponseMessageHelper.cs (2)
23private readonly HttpResponseMessage _httpResponseMessage; 27public HttpResponseMessageHelper(HttpResponseMessage httpResponseMessage, HttpChannelFactory<IRequestChannel> factory)
System\ServiceModel\Channels\HttpResponseMessageProperty.cs (4)
32internal HttpResponseMessageProperty(HttpResponseMessage httpResponseMessage) 114public HttpResponseMessage HttpResponseMessage 230public HttpResponseMessageBackedProperty(HttpResponseMessage httpResponseMessage) 237public HttpResponseMessage HttpResponseMessage { get; private set; }
Yarp.Frontend (1)
Program.cs (1)
21var response = await client.GetAsync("/api/weatherforecast");