302 instantiations of HttpResponseMessage
Aspire.Cli.Tests (170)
Agents\AspireSkillsInstallerTests.cs (14)
162return new HttpResponseMessage(HttpStatusCode.InternalServerError); 212return new HttpResponseMessage(HttpStatusCode.OK) 262return new HttpResponseMessage(HttpStatusCode.OK) 329return new HttpResponseMessage(HttpStatusCode.OK) 997return new HttpResponseMessage(HttpStatusCode.OK) 1292return new HttpResponseMessage(HttpStatusCode.ServiceUnavailable); 1353return new HttpResponseMessage(HttpStatusCode.ServiceUnavailable); 1577return new HttpResponseMessage(HttpStatusCode.OK) 1642return new HttpResponseMessage(HttpStatusCode.OK) 1691return new HttpResponseMessage(HttpStatusCode.OK) 1747return new HttpResponseMessage(HttpStatusCode.OK) 1957return new HttpResponseMessage(HttpStatusCode.ServiceUnavailable); 1989new MockHttpClientFactory(httpMessageHandler ?? new MockHttpMessageHandler(_ => new HttpResponseMessage(HttpStatusCode.NotFound))), 2178return new HttpResponseMessage(HttpStatusCode.OK)
Agents\SigstoreNpmProvenanceCheckerTests.cs (1)
1190using var response = new HttpResponseMessage(HttpStatusCode.OK)
Commands\AgentMcpCommandTests.cs (3)
51return new HttpResponseMessage(HttpStatusCode.OK) 58return new HttpResponseMessage(HttpStatusCode.OK) 63return new HttpResponseMessage(HttpStatusCode.NotFound);
Commands\ExportCommandTests.cs (7)
245return new System.Net.Http.HttpResponseMessage(System.Net.HttpStatusCode.OK) 252return new System.Net.Http.HttpResponseMessage(System.Net.HttpStatusCode.OK) 259return new System.Net.Http.HttpResponseMessage(System.Net.HttpStatusCode.OK) 264return new System.Net.Http.HttpResponseMessage(System.Net.HttpStatusCode.NotFound); 902return new System.Net.Http.HttpResponseMessage(System.Net.HttpStatusCode.OK) 912return new System.Net.Http.HttpResponseMessage(System.Net.HttpStatusCode.OK) 919return new System.Net.Http.HttpResponseMessage(System.Net.HttpStatusCode.NotFound);
Commands\TelemetryCommandTests.cs (11)
330return new HttpResponseMessage(HttpStatusCode.OK) 339return new HttpResponseMessage(HttpStatusCode.NotFound); 347return new HttpResponseMessage(statusCode.Value) 357return new HttpResponseMessage(baseProbeStatusCode.Value); 387var response = new HttpResponseMessage(HttpStatusCode.OK) 404var response = new HttpResponseMessage(HttpStatusCode.OK) 421var response = new HttpResponseMessage(HttpStatusCode.Unauthorized); 435var response = new HttpResponseMessage(HttpStatusCode.NotFound); 462var response = new HttpResponseMessage(HttpStatusCode.InternalServerError); 480return new HttpResponseMessage(HttpStatusCode.OK) 497var response = new HttpResponseMessage(HttpStatusCode.OK)
Commands\TelemetryLogsCommandTests.cs (24)
193return new HttpResponseMessage(HttpStatusCode.OK) 201return new HttpResponseMessage(HttpStatusCode.OK) 206return new HttpResponseMessage(HttpStatusCode.NotFound); 245return new HttpResponseMessage(HttpStatusCode.OK) 253return new HttpResponseMessage(HttpStatusCode.OK) 258return new HttpResponseMessage(HttpStatusCode.NotFound); 337return new HttpResponseMessage(HttpStatusCode.OK) 342return new HttpResponseMessage(HttpStatusCode.Unauthorized); 375return new HttpResponseMessage(HttpStatusCode.OK) 382return new HttpResponseMessage(HttpStatusCode.NotFound); 385return new HttpResponseMessage(HttpStatusCode.OK); 418return new HttpResponseMessage(HttpStatusCode.OK) 488return new HttpResponseMessage(HttpStatusCode.NotFound); 491return new HttpResponseMessage(HttpStatusCode.OK) 528return new HttpResponseMessage(HttpStatusCode.OK) 535return new HttpResponseMessage(HttpStatusCode.OK) 543return new HttpResponseMessage(HttpStatusCode.OK) 548return new HttpResponseMessage(HttpStatusCode.NotFound); 619return new HttpResponseMessage(HttpStatusCode.OK) 626return new HttpResponseMessage(HttpStatusCode.OK) 631return new HttpResponseMessage(HttpStatusCode.NotFound); 683return new HttpResponseMessage(HttpStatusCode.OK) 692return new HttpResponseMessage(HttpStatusCode.OK) 697return new HttpResponseMessage(HttpStatusCode.NotFound);
Commands\TelemetrySpansCommandTests.cs (16)
166return new HttpResponseMessage(HttpStatusCode.OK) 174return new HttpResponseMessage(HttpStatusCode.OK) 179return new HttpResponseMessage(HttpStatusCode.NotFound); 237return new HttpResponseMessage(HttpStatusCode.OK) 242return new HttpResponseMessage(HttpStatusCode.Unauthorized); 276return new HttpResponseMessage(HttpStatusCode.NotFound); 279return new HttpResponseMessage(HttpStatusCode.OK) 353return new HttpResponseMessage(HttpStatusCode.OK) 360return new HttpResponseMessage(HttpStatusCode.OK) 365return new HttpResponseMessage(HttpStatusCode.NotFound); 422return new HttpResponseMessage(HttpStatusCode.OK) 431return new HttpResponseMessage(HttpStatusCode.OK) 436return new HttpResponseMessage(HttpStatusCode.NotFound); 469return new HttpResponseMessage(HttpStatusCode.OK) 478return new HttpResponseMessage(HttpStatusCode.OK) 483return new HttpResponseMessage(HttpStatusCode.NotFound);
Commands\TelemetryTestHelper.cs (3)
96return new HttpResponseMessage(HttpStatusCode.OK) 106return new HttpResponseMessage(HttpStatusCode.OK) 113return new HttpResponseMessage(HttpStatusCode.NotFound);
Commands\TelemetryTracesCommandTests.cs (23)
106"/api/telemetry/resources" => new HttpResponseMessage(HttpStatusCode.OK) 110"/api/telemetry/traces" => new HttpResponseMessage(HttpStatusCode.OK) 114_ => new HttpResponseMessage(HttpStatusCode.NotFound) 193"/api/telemetry/resources" => new HttpResponseMessage(HttpStatusCode.OK) 197"/api/telemetry/traces" => new HttpResponseMessage(HttpStatusCode.OK) 201_ => new HttpResponseMessage(HttpStatusCode.NotFound) 411return new HttpResponseMessage(HttpStatusCode.OK) 419return new HttpResponseMessage(HttpStatusCode.OK) 424return new HttpResponseMessage(HttpStatusCode.NotFound); 482return new HttpResponseMessage(HttpStatusCode.OK) 487return new HttpResponseMessage(HttpStatusCode.Unauthorized); 557return new HttpResponseMessage(HttpStatusCode.OK) 564return new HttpResponseMessage(HttpStatusCode.OK) 569return new HttpResponseMessage(HttpStatusCode.NotFound); 641return new HttpResponseMessage(HttpStatusCode.OK) 648return new HttpResponseMessage(HttpStatusCode.OK) 653return new HttpResponseMessage(HttpStatusCode.NotFound); 688return new HttpResponseMessage(HttpStatusCode.OK) 697return new HttpResponseMessage(HttpStatusCode.OK) 702return new HttpResponseMessage(HttpStatusCode.NotFound); 735return new HttpResponseMessage(HttpStatusCode.OK) 744return new HttpResponseMessage(HttpStatusCode.OK) 749return new HttpResponseMessage(HttpStatusCode.NotFound);
Mcp\ApiDocs\ApiDocsCacheTests.cs (2)
27using var response = new HttpResponseMessage(HttpStatusCode.OK) 53using var response = new HttpResponseMessage(HttpStatusCode.OK)
Mcp\ApiDocs\ApiDocsFetcherTests.cs (3)
28using var response = new HttpResponseMessage(HttpStatusCode.OK) 54using var response = new HttpResponseMessage(HttpStatusCode.OK) 81using var response = new HttpResponseMessage(HttpStatusCode.OK)
Mcp\Docs\DocsCacheTests.cs (1)
26using var response = new HttpResponseMessage(HttpStatusCode.OK)
Mcp\Docs\DocsFetcherTests.cs (16)
33using var response = new HttpResponseMessage 52using var response = new HttpResponseMessage 74using var response = new HttpResponseMessage 98using var response = new HttpResponseMessage 124using var response = new HttpResponseMessage 153return new HttpResponseMessage { StatusCode = HttpStatusCode.NotModified }; 156var response = new HttpResponseMessage 177using var response = new HttpResponseMessage 223using var response = new HttpResponseMessage 243using var response = new HttpResponseMessage 262using var response = new HttpResponseMessage 286using var response = new HttpResponseMessage 326using var response = new HttpResponseMessage 357return new HttpResponseMessage { StatusCode = HttpStatusCode.NotModified }; 359return new HttpResponseMessage 403return Task.FromResult(new HttpResponseMessage(HttpStatusCode.OK)
Mcp\ExcludeFromMcpTests.cs (2)
562return new HttpResponseMessage(HttpStatusCode.OK) 568return new HttpResponseMessage(HttpStatusCode.OK)
Mcp\ListStructuredLogsToolTests.cs (8)
158return new HttpResponseMessage(HttpStatusCode.OK) 165return new HttpResponseMessage(HttpStatusCode.OK) 252return new HttpResponseMessage(HttpStatusCode.OK) 259return new HttpResponseMessage(HttpStatusCode.OK) 307return new HttpResponseMessage(HttpStatusCode.OK) 314return new HttpResponseMessage(HttpStatusCode.OK) 446return new HttpResponseMessage(HttpStatusCode.OK) 453return new HttpResponseMessage(HttpStatusCode.OK)
Mcp\ListTracesToolTests.cs (10)
130return new HttpResponseMessage(HttpStatusCode.OK) 137return new HttpResponseMessage(HttpStatusCode.OK) 237return new HttpResponseMessage(HttpStatusCode.OK) 244return new HttpResponseMessage(HttpStatusCode.OK) 292return new HttpResponseMessage(HttpStatusCode.OK) 299return new HttpResponseMessage(HttpStatusCode.OK) 396return new HttpResponseMessage(HttpStatusCode.OK) 402return new HttpResponseMessage(HttpStatusCode.OK) 488return new HttpResponseMessage(HttpStatusCode.OK) 495return new HttpResponseMessage(HttpStatusCode.OK)
ProfileCaptureServiceTests.cs (11)
45return new HttpResponseMessage(HttpStatusCode.OK); 104new MockHttpMessageHandler(new HttpResponseMessage(HttpStatusCode.OK)), 121new MockHttpMessageHandler(new HttpResponseMessage(HttpStatusCode.OK)), 144new MockHttpMessageHandler(new HttpResponseMessage(HttpStatusCode.OK)), 175new MockHttpMessageHandler(new HttpResponseMessage(HttpStatusCode.OK)), 228return new HttpResponseMessage(HttpStatusCode.OK); 296new MockHttpMessageHandler(new HttpResponseMessage(HttpStatusCode.OK)), 417var handler = CreateTelemetryHandler(_ => new HttpResponseMessage(HttpStatusCode.OK) 433var handler = CreateTelemetryHandler(_ => new HttpResponseMessage(HttpStatusCode.OK) 597return new HttpResponseMessage(HttpStatusCode.NotFound); 603return new HttpResponseMessage(HttpStatusCode.OK)
Telemetry\InternalMicrosoftDetectorTests.cs (15)
327"/user" => new HttpResponseMessage(HttpStatusCode.Unauthorized), 328_ => new HttpResponseMessage(HttpStatusCode.NotFound) 351_ => new HttpResponseMessage(HttpStatusCode.NotFound) 373"/user/memberships/orgs/microsoft" => new HttpResponseMessage(HttpStatusCode.NotFound), 374"/orgs/microsoft/public_members/testuser" => new HttpResponseMessage(HttpStatusCode.NoContent), 375_ => new HttpResponseMessage(HttpStatusCode.NotFound) 397"/user/memberships/orgs/microsoft" => new HttpResponseMessage(HttpStatusCode.NotFound), 398"/orgs/microsoft/public_members/testuser" => new HttpResponseMessage(HttpStatusCode.NotFound), 399_ => new HttpResponseMessage(HttpStatusCode.NotFound) 422_ => new HttpResponseMessage(HttpStatusCode.NotFound) 449"/user" => new HttpResponseMessage(HttpStatusCode.Unauthorized), 450_ => new HttpResponseMessage(HttpStatusCode.NotFound) 476return new HttpResponseMessage(HttpStatusCode.OK); 526return new HttpResponseMessage(HttpStatusCode.Unauthorized); 590return new HttpResponseMessage(statusCode)
Aspire.Dashboard.Tests (7)
Telemetry\DashboardTelemetrySenderTests.cs (2)
87return Task.FromResult(new HttpResponseMessage(telemetryEnabledResponseStatusCode.Value) { Content = new StringContent(telemetryEnabledResponseBody ?? string.Empty) }); 95return 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.Azure.Tests (18)
AcrLoginServiceTests.cs (4)
25return Task.FromResult(new HttpResponseMessage(HttpStatusCode.OK) 51var handler = new CallbackHttpMessageHandler((_, _) => Task.FromResult(new HttpResponseMessage(HttpStatusCode.BadRequest) 73var handler = new CallbackHttpMessageHandler((_, _) => Task.FromResult(new HttpResponseMessage(HttpStatusCode.NotFound) 95var handler = new CallbackHttpMessageHandler((_, _) => Task.FromResult(new HttpResponseMessage(HttpStatusCode.NotFound)
AzureSandboxesTests.cs (14)
1075return Task.FromResult(new HttpResponseMessage(HttpStatusCode.BadRequest) 1210return Task.FromResult(new HttpResponseMessage(HttpStatusCode.Forbidden)); 1241return Task.FromResult(new HttpResponseMessage(HttpStatusCode.Forbidden)); 1262using var secondsResponse = new HttpResponseMessage(HttpStatusCode.TooManyRequests); 1264using var dateResponse = new HttpResponseMessage(HttpStatusCode.TooManyRequests); 1292var response = new HttpResponseMessage(status); 1361return Task.FromResult(new HttpResponseMessage(HttpStatusCode.InternalServerError)); 1454var handler = new RecordingHandler(_ => Task.FromResult(new HttpResponseMessage(HttpStatusCode.Created) 1480var handler = new RecordingHandler(_ => Task.FromResult(new HttpResponseMessage(HttpStatusCode.BadRequest))); 1502var handler = new RecordingHandler(_ => Task.FromResult(new HttpResponseMessage(HttpStatusCode.Forbidden))); 1549var handler = new RecordingHandler(_ => Task.FromResult(new HttpResponseMessage(HttpStatusCode.NotFound))); 1568var handler = new RecordingHandler(_ => Task.FromResult(new HttpResponseMessage(HttpStatusCode.BadRequest) 1587var handler = new RecordingHandler(_ => Task.FromResult(new HttpResponseMessage(HttpStatusCode.BadRequest) 3126return new HttpResponseMessage(statusCode)
Aspire.Hosting.Foundry.Tests (1)
HostedAgentExtensionTests.cs (1)
817return new HttpResponseMessage(statusCode)
Aspire.Hosting.Tests (6)
Dcp\TestKubernetesService.cs (2)
53Response = new HttpResponseMessageWrapper(new HttpResponseMessage { StatusCode = System.Net.HttpStatusCode.NotFound }, "Not found") 268Response = new HttpResponseMessageWrapper(new HttpResponseMessage { StatusCode = System.Net.HttpStatusCode.NotFound }, ex.Message)
WithHttpCommandTests.cs (4)
50using var response = new HttpResponseMessage(HttpStatusCode.OK) 65using var response = new HttpResponseMessage(HttpStatusCode.OK) 84using var response = new HttpResponseMessage(HttpStatusCode.BadRequest) 576var response = new HttpResponseMessage(statusCode);
BlazorHosted.ClientServiceDefaults (1)
BackgroundExportHandler.cs (1)
30return Task.FromResult(new HttpResponseMessage(HttpStatusCode.OK));
BlazorStandalone.ClientServiceDefaults (1)
BackgroundExportHandler.cs (1)
34return Task.FromResult(new HttpResponseMessage(HttpStatusCode.OK));
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)
153return new() { Content = new StringContent(sentJsonOutput, Encoding.UTF8, "application/json") };
Microsoft.Extensions.AI.OpenAI.Tests (15)
OpenAIHostedFileClientTests.cs (14)
573? new HttpResponseMessage(HttpStatusCode.OK) { Content = new ByteArrayContent(fileData) } 574: new HttpResponseMessage(HttpStatusCode.OK) 607? new HttpResponseMessage(HttpStatusCode.OK) { Content = new ByteArrayContent(fileData) } 608: new HttpResponseMessage(HttpStatusCode.OK) 648new HttpResponseMessage(HttpStatusCode.OK) 673new HttpResponseMessage(HttpStatusCode.OK) 702? new HttpResponseMessage(HttpStatusCode.OK) { Content = new ByteArrayContent(fileData) } 703: new HttpResponseMessage(HttpStatusCode.OK) 730new HttpResponseMessage(HttpStatusCode.OK) 767new HttpResponseMessage(HttpStatusCode.OK) 802new HttpResponseMessage(HttpStatusCode.OK) 832return new HttpResponseMessage(HttpStatusCode.OK) 857new HttpResponseMessage(HttpStatusCode.OK) 903Task.FromResult(new HttpResponseMessage(HttpStatusCode.NotFound) { Content = new StringContent("{}") });
OpenAIResponseClientTests.cs (1)
6884return new HttpResponseMessage { Content = new StringContent(body) };
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 (42)
Latency\Internal\HttpClientLatencyLogEnricherTest.cs (2)
46using HttpResponseMessage httpResponseMessage = new(); 66using HttpResponseMessage httpResponseMessage = new();
Latency\Internal\HttpLatencyMediatorTests.cs (2)
69var resp = new HttpResponseMessage(); 120using var response = new HttpResponseMessage();
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)
660var response = new HttpResponseMessage(HttpStatusCode.OK); 695? 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 (10)
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 292using 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 (25)
Hedging\HedgingTests.cs (1)
334_responses.Enqueue(new HttpResponseMessage(statusCode));
Hedging\HttpClientHedgingResiliencePredicatesTests.cs (1)
42using var response = new HttpResponseMessage(code);
Hedging\StandardHedgingTests.cs (3)
116using var response = new HttpResponseMessage(HttpStatusCode.OK); 361return new HttpResponseMessage(HttpStatusCode.OK); 375return 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)
668var response = new HttpResponseMessage() { RequestMessage = request, Content = new HttpConnectionResponseContent() };
System.Net.Http.WinHttpHandler (1)
System\Net\Http\WinHttpResponseParser.cs (1)
25var response = new HttpResponseMessage();
1125 references to HttpResponseMessage
aspire (30)
Agents\AspireSkills\AspireSkillsInstaller.cs (2)
433using var response = await httpClient.SendAsync(request, cancellationToken).ConfigureAwait(false); 532using var response = await httpClient.SendAsync(request, HttpCompletionOption.ResponseHeadersRead, cancellationToken).ConfigureAwait(false);
Agents\AspireSkills\GitHubArtifactAttestationVerifier.cs (1)
49using var response = await httpClient.SendAsync(request, cancellationToken).ConfigureAwait(false);
Commands\ExportCommand.cs (2)
295var response = await client.GetAsync(url, cancellationToken).ConfigureAwait(false); 326var response = await client.GetAsync(url, cancellationToken).ConfigureAwait(false);
Commands\TelemetryCommandHelpers.cs (4)
128public static bool HasJsonContentType(HttpResponseMessage response) 149public static void EnsureTelemetryApiResponse(HttpResponseMessage response) 378var probeResponse = await probeClient.GetAsync(dashboardBaseUrl, cancellationToken).ConfigureAwait(false); 508var response = await client.GetAsync(url, cancellationToken).ConfigureAwait(false);
Commands\TelemetryLogsCommand.cs (2)
168var response = await client.GetAsync(url, cancellationToken); 190using var response = await client.GetAsync(url, HttpCompletionOption.ResponseHeadersRead, cancellationToken);
Commands\TelemetrySpansCommand.cs (2)
160var response = await client.GetAsync(url, cancellationToken); 182using var response = await client.GetAsync(url, HttpCompletionOption.ResponseHeadersRead, cancellationToken);
Commands\TelemetryTracesCommand.cs (2)
137var response = await client.GetAsync(url, cancellationToken); 206var response = await client.GetAsync(url, cancellationToken);
Documentation\CachedHttpDocumentFetcher.cs (2)
47using var response = await httpClient.SendAsync(request, cancellationToken).ConfigureAwait(false); 61using var retryResponse = await httpClient.GetAsync(url, cancellationToken).ConfigureAwait(false);
Mcp\Tools\ListStructuredLogsTool.cs (1)
99var response = await client.GetAsync(url, cancellationToken).ConfigureAwait(false);
Mcp\Tools\ListTracesTool.cs (1)
99var response = await client.GetAsync(url, cancellationToken).ConfigureAwait(false);
Mcp\Tools\ListTraceStructuredLogsTool.cs (1)
89var response = await client.GetAsync(url, cancellationToken).ConfigureAwait(false);
Npm\SigstoreNpmProvenanceChecker.cs (1)
158var response = await _httpClient.GetAsync(url, cancellationToken).ConfigureAwait(false);
Profiling\ProfileCaptureService.cs (2)
291using var response = await client.GetAsync(_options.DashboardUrl, linkedCts.Token).ConfigureAwait(false); 449using var response = await client.GetAsync(url, cancellationToken).ConfigureAwait(false);
Telemetry\InternalMicrosoftDetector.cs (4)
703using var userResponse = await http.SendAsync(userRequest, cancellationToken).ConfigureAwait(false); 716using var membershipResponse = await http.SendAsync(membershipRequest, cancellationToken).ConfigureAwait(false); 725using var publicMemberResponse = await http.SendAsync(publicMemberRequest, cancellationToken).ConfigureAwait(false); 749private static async Task<string?> ReadJsonPropertyAsync(HttpResponseMessage response, string propertyName, CancellationToken cancellationToken)
Utils\CliDownloader.cs (1)
199using var response = await s_httpClient.GetAsync(url, HttpCompletionOption.ResponseHeadersRead, cts.Token);
Utils\EnvironmentChecker\DcpConnectionChecker.cs (2)
63using var response = await client.GetAsync(new Uri(kubeconfig.Server, "/version"), timeoutCts.Token).ConfigureAwait(false); 339using var response = await client.SendAsync(request, cancellationToken).ConfigureAwait(false);
Aspire.Acquisition.Tests (1)
Scripts\Common\ScriptHostFixture.cs (1)
79using var response = await client.GetAsync($"{BaseUrl}/get-aspire-cli.sh");
Aspire.Cli.EndToEnd.Tests (4)
Helpers\CliE2ETestHelpers.cs (4)
640using var response = await s_nuGetHttpClient.GetAsync(indexUrl, cancellationToken); 790using var response = await s_nuGetHttpClient.GetAsync(stagingDownloadUrl, HttpCompletionOption.ResponseHeadersRead, cancellationToken); 830using var response = await s_nuGetHttpClient.SendAsync(request, HttpCompletionOption.ResponseHeadersRead, cancellationToken); 872using var response = await s_nuGetHttpClient.GetAsync(indexUrl, HttpCompletionOption.ResponseHeadersRead, cancellationToken);
Aspire.Cli.Tests (38)
Agents\AspireSkillsInstallerTests.cs (1)
2176private static HttpResponseMessage CreateJsonResponse(string json)
Agents\SigstoreNpmProvenanceCheckerTests.cs (1)
1190using var response = new HttpResponseMessage(HttpStatusCode.OK)
Commands\TelemetryCommandTests.cs (6)
387var response = new HttpResponseMessage(HttpStatusCode.OK) 404var response = new HttpResponseMessage(HttpStatusCode.OK) 421var response = new HttpResponseMessage(HttpStatusCode.Unauthorized); 435var response = new HttpResponseMessage(HttpStatusCode.NotFound); 462var response = new HttpResponseMessage(HttpStatusCode.InternalServerError); 497var response = new HttpResponseMessage(HttpStatusCode.OK)
Mcp\ApiDocs\ApiDocsCacheTests.cs (2)
27using var response = new HttpResponseMessage(HttpStatusCode.OK) 53using var response = new HttpResponseMessage(HttpStatusCode.OK)
Mcp\ApiDocs\ApiDocsFetcherTests.cs (3)
28using var response = new HttpResponseMessage(HttpStatusCode.OK) 54using var response = new HttpResponseMessage(HttpStatusCode.OK) 81using var response = new HttpResponseMessage(HttpStatusCode.OK)
Mcp\Docs\DocsCacheTests.cs (1)
26using var response = new HttpResponseMessage(HttpStatusCode.OK)
Mcp\Docs\DocsFetcherTests.cs (13)
33using var response = new HttpResponseMessage 52using var response = new HttpResponseMessage 74using var response = new HttpResponseMessage 98using var response = new HttpResponseMessage 124using var response = new HttpResponseMessage 156var response = new HttpResponseMessage 177using var response = new HttpResponseMessage 223using var response = new HttpResponseMessage 243using var response = new HttpResponseMessage 262using var response = new HttpResponseMessage 286using var response = new HttpResponseMessage 326using var response = new HttpResponseMessage 398protected override Task<HttpResponseMessage> SendAsync(
ProfileCaptureServiceTests.cs (3)
585Func<HttpRequestMessage, HttpResponseMessage> telemetryResponseFactory, 592var response = telemetryResponseFactory(request); 601private static HttpResponseMessage JsonResponse(TelemetryApiResponse response)
Telemetry\InternalMicrosoftDetectorTests.cs (3)
588private static HttpResponseMessage JsonResponse(HttpStatusCode statusCode, string json) 638private sealed class TestGitHubHttpMessageHandler(Func<HttpRequestMessage, CancellationToken, Task<HttpResponseMessage>> sendAsync) : HttpMessageHandler 651protected override async Task<HttpResponseMessage> SendAsync(HttpRequestMessage request, CancellationToken cancellationToken)
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 (2)
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 (86)
Integration\BlazorWebSocketOriginTests.cs (1)
25using var response = await client.SendAsync(request).DefaultTimeout();
Integration\FrontendBrowserTokenAuthTests.cs (15)
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(); 110var response1 = await client.GetAsync(DashboardUrls.LoginUrl(returnUrl: DashboardUrls.TracesUrl(), token: apiKey)).DefaultTimeout(); 115var response2 = await client.GetAsync(new Uri(httpBaseAddress, DashboardUrls.LoginUrl(returnUrl: DashboardUrls.TracesUrl(), token: apiKey))).DefaultTimeout(); 120var response3 = await client.GetAsync(new Uri(httpBaseAddress, DashboardUrls.StructuredLogsUrl())).DefaultTimeout(); 152var httpsResponse = await client.GetAsync(new Uri(new Uri(httpsEndpoint.GetResolvedAddress()), DashboardUrls.LoginUrl(returnUrl: DashboardUrls.TracesUrl(), token: apiKey))).DefaultTimeout(); 153var httpResponse = await client.GetAsync(new Uri(new Uri(httpEndpoint.GetResolvedAddress()), DashboardUrls.LoginUrl(returnUrl: DashboardUrls.TracesUrl(), token: apiKey))).DefaultTimeout(); 197var signoutResponse = await client.GetAsync(new Uri(httpsBaseAddress, "/api/signout")).DefaultTimeout(); 237var response1 = await client.GetAsync(DashboardUrls.LoginUrl(returnUrl: DashboardUrls.TracesUrl(), token: apiKey)).DefaultTimeout(); 242var response2 = await client.GetAsync(DashboardUrls.StructuredLogsUrl()).DefaultTimeout(); 272var response = await client.GetAsync(DashboardUrls.LoginUrl(returnUrl: DashboardUrls.TracesUrl(), token: apiKey)).DefaultTimeout(); 297var response = await client.GetAsync(DashboardUrls.LoginUrl(returnUrl: DashboardUrls.TracesUrl(), token: apiKey)).DefaultTimeout(); 321var response = await client.GetAsync(DashboardUrls.LoginUrl(returnUrl: DashboardUrls.TracesUrl(), token: "Wrong!")).DefaultTimeout(); 346var response = await client.PostAsJsonAsync("/api/validatetoken", new { Token = requestToken }).DefaultTimeout();
Integration\FrontendOpenIdConnectAuthTests.cs (2)
39var response = await client.GetAsync("/").DefaultTimeout(); 84var response = await client.GetAsync("/").DefaultTimeout();
Integration\HealthTests.cs (2)
36var response = await client.SendAsync(request).DefaultTimeout(); 53var response = await client.GetAsync($"/{DashboardUrls.HealthBasePath}").DefaultTimeout();
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 (9)
510var responseMessage = await httpClient.PostAsync("/v1/traces", content).DefaultTimeout(); 570var responseMessage = await httpClient.PostAsync("/v1/logs", content).DefaultTimeout(); 647var responseMessage = await httpClient.PostAsync("/v1/logs", content).DefaultTimeout(); 697var responseMessage = await httpClient.PostAsync("/v1/metrics", content).DefaultTimeout(); 749var responseMessage = await httpClient.PostAsync("/v1/metrics", content).DefaultTimeout(); 843var responseMessage = await httpClient.SendAsync(requestMessage).DefaultTimeout(); 867var responseMessage = await httpClient.PostAsync("/v1/logs", content).DefaultTimeout(); 885var responseMessage = await httpClient.PostAsync("/v1/logs", content).DefaultTimeout(); 903var responseMessage = await httpClient.PostAsync("/v1/logs", content).DefaultTimeout();
Integration\OtlpHttpServiceTests.cs (12)
53var responseMessage = await httpClient.PostAsync("/v1/logs", content).DefaultTimeout(TestConstants.LongTimeoutDuration); 79var responseMessage = await httpClient.PostAsync("/v1/logs", content).DefaultTimeout(); 126var responseMessage = await httpClient.PostAsync("/v1/logs", content).DefaultTimeout(); 154var responseMessage = await httpClient.SendAsync(requestMessage).DefaultTimeout(); 182var responseMessage = await httpClient.SendAsync(requestMessage).DefaultTimeout(); 216var responseMessage = await httpClient.PostAsync("/v1/logs", content).DefaultTimeout(); 246var responseMessage = await client.PostAsync("/v1/logs", content).DefaultTimeout(); 277var responseMessage = await client.PostAsync("/v1/logs", content).DefaultTimeout(); 323var responseMessage = await client.SendAsync(requestMessage).DefaultTimeout(); 346var responseMessage = await client.PostAsync("/v1/logs", content).DefaultTimeout(); 375var responseMessage = await client.PostAsync("/v1/traces", content).DefaultTimeout(); 404var 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 (5)
419var response = await httpClient.SendAsync(request).DefaultTimeout(); 520var responseMessage = await httpClient.SendAsync(request).DefaultTimeout(); 800var response = await httpClient.GetAsync("/api/telemetry/spans").DefaultTimeout(); 947var response = await client.GetAsync("/").DefaultTimeout(); 1026var response = await client.SendAsync(request).DefaultTimeout();
Integration\TelemetryApiTests.cs (20)
68var response = await httpClient.GetAsync("/api/telemetry/spans").DefaultTimeout(); 88var response = await httpClient.GetAsync("/api/telemetry/spans").DefaultTimeout(); 114var response = await httpClient.GetAsync("/api/telemetry/spans").DefaultTimeout(); 141var response = await httpClient.GetAsync("/api/telemetry/spans").DefaultTimeout(); 160var response = await httpClient.GetAsync("/api/telemetry/logs").DefaultTimeout(); 182var response = await httpClient.GetAsync("/api/telemetry/logs?traceId=some-trace-id").DefaultTimeout(); 204var response = await httpClient.GetAsync($"/api/telemetry/spans?hasError=true&limit={int.MaxValue}").DefaultTimeout(); 225var response = await httpClient.GetAsync("/api/telemetry/spans?resource=unknown-resource").DefaultTimeout(); 244var response = await httpClient.GetAsync($"/api/telemetry/logs?severity=Error&limit={int.MaxValue}").DefaultTimeout(); 265var response = await httpClient.GetAsync("/api/telemetry/logs?resource=unknown-resource").DefaultTimeout(); 285var response = await httpClient.GetAsync("/api/telemetry/spans").DefaultTimeout(); 309var response = await httpClient.GetAsync("/api/telemetry/spans").DefaultTimeout(); 335var response = await httpClient.GetAsync("/api/telemetry/spans").DefaultTimeout(); 357using var response = await httpClient.GetAsync("/api/telemetry/spans?follow=true", HttpCompletionOption.ResponseHeadersRead, cts.Token).DefaultTimeout(); 388var response = await httpClient.GetAsync("/api/telemetry/logs?follow=true", HttpCompletionOption.ResponseHeadersRead, cts.Token).DefaultTimeout(); 418var response = await httpClient.GetAsync("/api/telemetry/traces").DefaultTimeout(); 440var response = await httpClient.GetAsync("/api/telemetry/traces?hasError=true&limit=10").DefaultTimeout(); 462var response = await httpClient.GetAsync("/api/telemetry/traces?resource=unknownresource").DefaultTimeout(); 481var response = await httpClient.GetAsync("/api/telemetry/traces/nonexistent-trace-id").DefaultTimeout(); 504var response = await httpClient.GetAsync("/api/telemetry/traces").DefaultTimeout();
Middleware\ValidateTokenMiddlewareTests.cs (8)
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(); 75var response = await host.GetTestClient().GetAsync($"/login?t=test&returnUrl={Uri.EscapeDataString(returnUrl)}").DefaultTimeout(); 88var response = await host.GetTestClient().GetAsync($"/login?t=token&returnUrl={Uri.EscapeDataString(returnUrl)}").DefaultTimeout();
Telemetry\DashboardTelemetrySenderTests.cs (5)
85return Task.FromException<HttpResponseMessage>(new InvalidOperationException()); 93return Task.FromException<HttpResponseMessage>(new InvalidOperationException()); 156private readonly Func<HttpRequestMessage, CancellationToken, Task<HttpResponseMessage>> _value; 158public TestHttpMessageHandler(Func<HttpRequestMessage, CancellationToken, Task<HttpResponseMessage>> value) 163protected 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 (7)
ApplicationModel\HttpCommandContext.cs (1)
150public 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);
ExternalServiceBuilderExtensions.cs (1)
351using var response = await httpClientFactory().GetAsync(uri, HttpCompletionOption.ResponseHeadersRead, linkedSource.Token).ConfigureAwait(false);
ResourceBuilderExtensions.cs (2)
3739HttpResponseMessage? response = null; 3872internal static async Task<ExecuteCommandResult> GetDefaultHttpCommandResultAsync(HttpResponseMessage response, HttpCommandOptions commandOptions, CancellationToken cancellationToken)
Aspire.Hosting.Azure (1)
AcrLoginService.cs (1)
167var response = await httpClient.PostAsync(exchangeUrl, content, cancellationToken).ConfigureAwait(false);
Aspire.Hosting.Azure.Sandboxes (10)
AzureSandboxContainerDeployment.cs (1)
2159using var response = await httpClient.GetAsync(publicUrl.TrimEnd('/'), cancellationToken).ConfigureAwait(false);
Internal\Adc\AzureDevComputeClient.cs (9)
191using var response = await SendWithRetryAsync(scope, method, path, content, cancellationToken).ConfigureAwait(false); 208using var response = await SendWithRetryAsync(scope, method, path, content, cancellationToken).ConfigureAwait(false); 227HttpResponseMessage response; 295private async Task<HttpResponseMessage> SendWithRetryAsync( 305HttpResponseMessage response; 383HttpResponseMessage response, 412private async Task<HttpResponseMessage> SendCoreAsync( 454private static async Task EnsureSuccessAsync(HttpResponseMessage response, HttpMethod method, string path, CancellationToken cancellationToken) 468private static Task<string> GetErrorMessageAsync(HttpResponseMessage response, CancellationToken cancellationToken)
Aspire.Hosting.Azure.Tests (10)
AcrLoginServiceTests.cs (2)
117private sealed class CallbackHttpMessageHandler(Func<int, CancellationToken, Task<HttpResponseMessage>> callback) : HttpMessageHandler 121protected override Task<HttpResponseMessage> SendAsync(HttpRequestMessage request, CancellationToken cancellationToken)
AzureSandboxesTests.cs (8)
1262using var secondsResponse = new HttpResponseMessage(HttpStatusCode.TooManyRequests); 1264using var dateResponse = new HttpResponseMessage(HttpStatusCode.TooManyRequests); 1292var response = new HttpResponseMessage(status); 1315? Task.FromException<HttpResponseMessage>(new HttpRequestException("connection reset")) 1336return Task.FromException<HttpResponseMessage>(new HttpRequestException("connection reset")); 3051private sealed class RecordingHandler(Func<HttpRequestMessage, Task<HttpResponseMessage>> handler) : HttpMessageHandler 3053protected override Task<HttpResponseMessage> SendAsync(HttpRequestMessage request, CancellationToken cancellationToken) 3124private static HttpResponseMessage JsonResponse(string content, HttpStatusCode statusCode = HttpStatusCode.OK)
Aspire.Hosting.Browsers (1)
BrowserEndpointDiscovery.cs (1)
213using var response = await s_probeHttpClient.GetAsync(versionEndpoint, probeCts.Token).ConfigureAwait(false);
Aspire.Hosting.Browsers.Tests (1)
src\Aspire.Hosting.Browsers\BrowserEndpointDiscovery.cs (1)
213using var response = await s_probeHttpClient.GetAsync(versionEndpoint, probeCts.Token).ConfigureAwait(false);
Aspire.Hosting.Foundry (1)
HostedAgent\HostedAgentBuilderExtension.cs (1)
357var response = ctx.Response;
Aspire.Hosting.Foundry.Tests (1)
HostedAgentExtensionTests.cs (1)
810protected override async Task<HttpResponseMessage> SendAsync(HttpRequestMessage request, CancellationToken cancellationToken)
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)
93var response = await client.GetAsync(path); 178var response = await client.PostAsync("/api/connect", httpContent);
Aspire.Hosting.Redis.Tests (6)
RedisFunctionalTests.cs (6)
94var response = await client.GetAsync(path); 196var response = await client.GetAsync("/api/databases", cts.Token); 227var testConnectionResponse = await client.GetAsync($"/api/databases/{db.Id}/connect", cts2.Token); 602var response = await httpClient.GetAsync("/api/settings", ct); 634var response = await client.PatchAsync(apiUrl, jsonContent, ct); 690var httpResponse = await client.GetAsync(redisCommanderUrl!);
Aspire.Hosting.Seq.Tests (2)
SeqFunctionalTests.cs (2)
57var ingestResponse = await httpClient.PostAsync("/ingest/clef", content, token); 60var response = await httpClient.GetAsync("/api/events?filter=Username='johndoe'", token);
Aspire.Hosting.Testing.Tests (5)
DashboardUrlTests.cs (5)
47using var loginResponse = await httpClient.GetAsync(dashboardUri, cancellationTokenSource.Token); 55using var protectedResponse = await httpClient.GetAsync( 183using var loginResponse = await httpClient.GetAsync(dashboardUri, cancellationTokenSource.Token); 228using var response = await httpClient.GetAsync(invalidLoginUrl, cancellationTokenSource.Token); 270using var response = await httpClient.GetAsync(dashboardUri, cancellationTokenSource.Token);
Aspire.Hosting.Tests (8)
ContainerTunnelTests.cs (2)
38var response = await clientA.GetAsync("/servicea/").DefaultTimeout(TestConstants.DefaultOrchestratorTestTimeout); 77var response = await clientA.GetAsync("/servicea/").DefaultTimeout(TestConstants.DefaultOrchestratorTestTimeout);
WithHttpCommandTests.cs (6)
50using var response = new HttpResponseMessage(HttpStatusCode.OK) 65using var response = new HttpResponseMessage(HttpStatusCode.OK) 84using var response = new HttpResponseMessage(HttpStatusCode.BadRequest) 564protected override async Task<HttpResponseMessage> SendAsync(HttpRequestMessage request, CancellationToken cancellationToken) 576var response = new HttpResponseMessage(statusCode); 592protected override Task<HttpResponseMessage> SendAsync(HttpRequestMessage request, CancellationToken cancellationToken)
Aspire.Hosting.Yarp.Tests (2)
YarpFunctionalTests.cs (2)
59using var response200 = await httpClient.GetAsync("/aspnetapp"); 62using var response404 = await httpClient.GetAsync("/another");
Aspire.Playground.Tests (12)
AppHostTests.cs (1)
126HttpResponseMessage? response = null;
BlazorWasmHostingTests.cs (8)
26var homeResponse = await blazorClient.GetAsync("/"); 31var configResponse = await blazorClient.GetAsync("/_blazor/_configuration"); 34var proxyApiResponse = await blazorClient.GetAsync("/_api/weatherapi/weatherforecast"); 40var directApiResponse = await weatherApiClient.GetAsync("/weatherforecast"); 107var homeResponse = await gatewayClient.GetAsync("/app/"); 112var configResponse = await gatewayClient.GetAsync("/app/_blazor/_configuration"); 115var apiResponse = await gatewayClient.GetAsync("/app/_api/weatherapi/weatherforecast"); 121var directApiResponse = await weatherApiClient.GetAsync("/weatherforecast");
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)
24using 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);
BlazorHosted.ClientServiceDefaults (4)
BackgroundExportHandler.cs (3)
16ResiliencePipeline<HttpResponseMessage> pipeline, 19protected override Task<HttpResponseMessage> SendAsync( 38var response = await pipeline.ExecuteAsync(async token =>
Extensions.cs (1)
51var pipeline = new ResiliencePipelineBuilder<HttpResponseMessage>()
BlazorStandalone.ClientServiceDefaults (4)
BackgroundExportHandler.cs (3)
16ResiliencePipeline<HttpResponseMessage> pipeline, 19protected override Task<HttpResponseMessage> SendAsync( 42var response = await pipeline.ExecuteAsync(async token =>
Extensions.cs (1)
51var pipeline = new ResiliencePipelineBuilder<HttpResponseMessage>()
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-aot (2)
src\sdk\src\Cli\dotnet\NugetSearch\NugetToolSearchApiRequest.cs (2)
30HttpResponseMessage response = await httpClient.GetAsync(queryUrl, cancellation.Token); 100HttpResponseMessage response;
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)
604var parResponseMessage = await Backchannel.SendAsync(requestMessage, Context.RequestAborted); 613private async Task<string> GetPushedAuthorizationRequestUri(HttpResponseMessage parResponseMessage) 1000var responseMessage = await Backchannel.SendAsync(requestMessage, Context.RequestAborted); 1066var responseMessage = await Backchannel.SendAsync(requestMessage, Context.RequestAborted); 1520private OpenIdConnectProtocolException CreateOpenIdConnectProtocolException(OpenIdConnectMessage message, HttpResponseMessage? response)
Microsoft.AspNetCore.Authentication.Twitter (5)
TwitterHandler.cs (5)
184private 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) 274var response = await ExecuteRequestAsync(TwitterDefaults.RequestTokenEndpoint, HttpMethod.Post, extraOAuthPairs: new Dictionary<string, string>() { { "oauth_callback", callBackUri } }); 300var response = await ExecuteRequestAsync(TwitterDefaults.AccessTokenEndpoint, HttpMethod.Post, token, formData: formPost); 325var response = await ExecuteRequestAsync("https://api.twitter.com/1.1/account/verify_credentials.json", HttpMethod.Get, accessToken, queryParameters: new Dictionary<string, string>() { { "include_email", "true" } }); 357private 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.Components.WebAssembly.Authentication (3)
Services\AuthorizationMessageHandler.cs (2)
13/// A <see cref="DelegatingHandler"/> that attaches access tokens to outgoing <see cref="HttpResponseMessage"/> instances. 48protected override async Task<HttpResponseMessage> SendAsync(HttpRequestMessage request, CancellationToken cancellationToken)
Services\BaseAddressAuthorizationMessageHandler.cs (1)
9/// A <see cref="DelegatingHandler"/> that attaches access tokens to outgoing <see cref="HttpResponseMessage"/> instances.
Microsoft.AspNetCore.Diagnostics.Middleware.Tests (22)
Latency\ChecpointAcceptanceTests.cs (2)
103HttpResponseMessage? response = null; 127using var response = await host.GetTestServer().CreateClient().GetAsync("/Path");
Logging\AcceptanceTests.cs (14)
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); 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)
493using (var response = await httpClient.SendAsync(request, HttpCompletionOption.ResponseHeadersRead, cancellationToken).ConfigureAwait(false)) 789using 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) 65var 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.Cli.Telemetry (1)
Implementation\HttpTelemetryUploadTransport.cs (1)
51using var response = await _client.SendAsync(request, cancellationToken).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)
46protected override async Task<HttpResponseMessage> SendAsync(
Microsoft.Extensions.AI.OpenAI.Tests (6)
OpenAIHostedFileClientTests.cs (3)
902protected override Task<HttpResponseMessage> SendAsync(HttpRequestMessage request, CancellationToken cancellationToken) => 906private sealed class RoutingHandler(Func<HttpRequestMessage, HttpResponseMessage> handler) : HttpMessageHandler 908protected override Task<HttpResponseMessage> SendAsync(HttpRequestMessage request, CancellationToken cancellationToken) =>
OpenAIRequestPoliciesTests.cs (1)
163protected override Task<HttpResponseMessage> SendAsync(HttpRequestMessage request, System.Threading.CancellationToken cancellationToken)
OpenAIResponseClientTests.cs (1)
6878protected override async Task<HttpResponseMessage> SendAsync(HttpRequestMessage request, System.Threading.CancellationToken cancellationToken)
ThrowUserAgentExceptionHandler.cs (1)
13protected override Task<HttpResponseMessage> SendAsync(HttpRequestMessage request, CancellationToken cancellationToken) =>
Microsoft.Extensions.DataIngestion.Tests (4)
Readers\DocumentReaderConformanceTests.cs (4)
80using HttpResponseMessage response = await DownloadAsync(new(source)); 152protected static async Task<HttpResponseMessage> DownloadAsync(Uri uri) 156HttpResponseMessage 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.netfx.cs (1)
19public 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) 93private 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)
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)
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)
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
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)
Microsoft.Extensions.Http.Diagnostics.Tests (74)
Latency\Internal\HttpClientLatencyLogEnricherTest.cs (2)
46using HttpResponseMessage httpResponseMessage = new(); 66using HttpResponseMessage httpResponseMessage = new();
Latency\Internal\HttpLatencyMediatorTests.cs (3)
69var resp = new HttpResponseMessage(); 71mockHandler.Protected().Setup<Task<HttpResponseMessage>>( 120using var response = new HttpResponseMessage();
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)
660var response = new HttpResponseMessage(HttpStatusCode.OK); 671using var response = await client.GetAsync("http://localhost/api"); 738private sealed class TestMessageHandler(Func<HttpRequestMessage, HttpResponseMessage> responseFactory) 741protected override Task<HttpResponseMessage> SendAsync(HttpRequestMessage request, CancellationToken cancellationToken) 751protected 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 (10)
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 292using 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 (92)
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 (14)
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) 365protected override HttpResponseMessage Send(HttpRequestMessage request, CancellationToken cancellationToken)
Helpers\TestHandlerStub.cs (4)
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) 32protected override HttpResponseMessage Send(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.TestFrameworkCommon (1)
TestDownloadUtils.cs (1)
31using (var response = client.GetAsync(url, HttpCompletionOption.ResponseHeadersRead, cancellationSource.Token).GetAwaiter().GetResult())
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 (33)
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 (6)
31using HttpResponseMessage response = await _client.SendAsync(request, cancellationToken).ConfigureAwait(false); 40public async Task<HttpResponseMessage> GetAsync(string repositoryName, string reference, CancellationToken cancellationToken) 44HttpResponseMessage response = await _client.SendAsync(request, cancellationToken).ConfigureAwait(false); 50_ => await LogAndThrowContainerHttpException<HttpResponseMessage>(response, cancellationToken).ConfigureAwait(false) 59HttpResponseMessage putResponse = await _client.PutAsync(new Uri(_baseUri, $"/v2/{repositoryName}/manifests/{reference}"), manifestUploadContent, cancellationToken).ConfigureAwait(false); 68private 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)
16public Task<HttpResponseMessage> GetAsync(string repositoryName, string reference, CancellationToken cancellationToken);
Registry\Registry.cs (3)
194using HttpResponseMessage initialManifestResponse = await _registryAPI.Manifest.GetAsync(repositoryName, reference, cancellationToken).ConfigureAwait(false); 242using HttpResponseMessage initialManifestResponse = await _registryAPI.Manifest.GetAsync(repositoryName, reference, cancellationToken).ConfigureAwait(false); 390using 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)
224internal async Task<IReadOnlyList<PackageSearchMetadata>> ProcessHttpStreamTakeCountedItemAsync(HttpResponseMessage? httpInitialResponse, int take, CancellationToken token) 235private async Task<V3SearchResults?> ProcessHttpStreamWithoutBufferingAsync(HttpResponseMessage? httpInitialResponse, uint take, CancellationToken token) 256private static async Task<V3SearchResults?> ProcessHttpStreamWithStjAsync(HttpResponseMessage httpInitialResponse, uint take, CancellationToken token) 273private static async Task<V3SearchResults?> ProcessHttpStreamWithNsjAsync(HttpResponseMessage httpInitialResponse, uint take, CancellationToken token)
Resources\PackageUpdateResource.cs (1)
535private 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)
171var 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)
354protected internal override HttpResponseMessage Send(HttpRequestMessage request, CancellationToken cancellationToken) 364protected 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)
158internal override ValueTask<HttpResponseMessage> SendAsync(HttpRequestMessage request, bool async, CancellationToken cancellationToken) 167new ValueTask<HttpResponseMessage>(_innerHandler.SendAsync(request, cancellationToken)) : 168new ValueTask<HttpResponseMessage>(_innerHandler.Send(request, cancellationToken)); 172private async ValueTask<HttpResponseMessage> SendAsyncWithMetrics(HttpRequestMessage request, bool async, CancellationToken cancellationToken) 177HttpResponseMessage? response = null; 221private void RequestStop(HttpRequestMessage request, HttpResponseMessage? response, Exception? exception, long startTimestamp, bool recordCurrentRequests, ActiveRequestsTagKey requestTagKey)
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)
356public ValueTask<HttpResponseMessage> SendAsync(HttpRequestMessage request, bool async, bool doRequestAuth, CancellationToken cancellationToken) 375public ValueTask<HttpResponseMessage> SendWithProxyAuthAsync(HttpRequestMessage request, bool async, bool doRequestAuth, CancellationToken cancellationToken) 385private Task<HttpResponseMessage> SendWithNtConnectionAuthAsync(HttpConnection connection, HttpRequestMessage request, bool async, bool doRequestAuth, CancellationToken cancellationToken) 395public Task<HttpResponseMessage> SendWithNtProxyAuthAsync(HttpConnection connection, HttpRequestMessage request, bool async, CancellationToken cancellationToken) 405public async ValueTask<HttpResponseMessage> SendWithVersionDetectionAndRetryAsync(HttpRequestMessage request, bool async, bool doRequestAuth, CancellationToken cancellationToken) 422HttpResponseMessage? response = null; 809HttpResponseMessage tunnelResponse = await _poolManager.SendProxyConnectAsync(tunnelRequest, _proxyUri!, async, cancellationToken).ConfigureAwait(false);
System\Net\Http\SocketsHttpHandler\ConnectionPool\HttpConnectionPool.Http3.cs (3)
64private async ValueTask<HttpResponseMessage?> TrySendUsingHttp3Async(HttpRequestMessage request, CancellationToken cancellationToken) 108HttpResponseMessage response = await connection.SendAsync(request, waitForConnectionActivity, streamAvailable, cancellationToken).ConfigureAwait(false); 638private 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)
2078public async Task<HttpResponseMessage> SendAsync(HttpRequestMessage request, bool async, CancellationToken cancellationToken) 2147HttpResponseMessage 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)
266public async Task<HttpResponseMessage> SendAsync(HttpRequestMessage request, WaitForHttp3ConnectionActivity waitForConnectionActivity, bool streamAvailable, CancellationToken cancellationToken) 338Task<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)
533public async Task<HttpResponseMessage> SendAsync(HttpRequestMessage request, bool async, CancellationToken cancellationToken) 668var response = new HttpResponseMessage() { RequestMessage = request, Content = new HttpConnectionResponseContent() }; 1032private bool ParseStatusLine(HttpResponseMessage response) 1061private static void ParseStatusLineCore(Span<byte> line, HttpResponseMessage response) 1134private bool ParseHeaders(HttpResponseMessage? response, bool isFromTrailer) 1153private (bool finished, int bytesConsumed) ParseHeadersCore(Span<byte> buffer, HttpResponseMessage? response, bool isFromTrailer) 1232private void AddResponseHeader(ReadOnlySpan<byte> name, ReadOnlySpan<byte> value, HttpResponseMessage response, bool isFromTrailer) 2100public 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)
354public ValueTask<HttpResponseMessage> SendAsyncCore(HttpRequestMessage request, Uri? proxyUri, bool async, bool doRequestAuth, bool isProxyConnect, CancellationToken cancellationToken) 404public ValueTask<HttpResponseMessage> SendProxyConnectAsync(HttpRequestMessage request, Uri proxyUri, bool async, CancellationToken cancellationToken) 409public ValueTask<HttpResponseMessage> SendAsync(HttpRequestMessage request, bool async, bool doRequestAuth, CancellationToken cancellationToken) 462private 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)
645protected internal override HttpResponseMessage Send(HttpRequestMessage request, 676protected internal override Task<HttpResponseMessage> SendAsync(HttpRequestMessage request, CancellationToken cancellationToken) 684return Task.FromCanceled<HttpResponseMessage>(cancellationToken); 690return Task.FromException<HttpResponseMessage>(error); 700async 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");