HttpResponseMessage

Commands\ExportCommandTests.cs (7)

246return new System.Net.Http.HttpResponseMessage(System.Net.HttpStatusCode.OK) 253return new System.Net.Http.HttpResponseMessage(System.Net.HttpStatusCode.OK) 260return new System.Net.Http.HttpResponseMessage(System.Net.HttpStatusCode.OK) 265return new System.Net.Http.HttpResponseMessage(System.Net.HttpStatusCode.NotFound); 723return new System.Net.Http.HttpResponseMessage(System.Net.HttpStatusCode.OK) 733return new System.Net.Http.HttpResponseMessage(System.Net.HttpStatusCode.OK) 740return new System.Net.Http.HttpResponseMessage(System.Net.HttpStatusCode.NotFound);

Commands\TelemetryTestHelper.cs (3)

94return new HttpResponseMessage(HttpStatusCode.OK) 104return new HttpResponseMessage(HttpStatusCode.OK) 111return new HttpResponseMessage(HttpStatusCode.NotFound);

Mcp\Docs\DocsFetcherTests.cs (16)

Mcp\ListStructuredLogsToolTests.cs (6)

158return new HttpResponseMessage(HttpStatusCode.OK) 165return new HttpResponseMessage(HttpStatusCode.OK) 261return new HttpResponseMessage(HttpStatusCode.OK) 268return new HttpResponseMessage(HttpStatusCode.OK) 316return new HttpResponseMessage(HttpStatusCode.OK) 323return new HttpResponseMessage(HttpStatusCode.OK)

Mcp\ListTracesToolTests.cs (8)

130return new HttpResponseMessage(HttpStatusCode.OK) 137return new HttpResponseMessage(HttpStatusCode.OK) 243return new HttpResponseMessage(HttpStatusCode.OK) 250return new HttpResponseMessage(HttpStatusCode.OK) 298return new HttpResponseMessage(HttpStatusCode.OK) 305return new HttpResponseMessage(HttpStatusCode.OK) 402return new HttpResponseMessage(HttpStatusCode.OK) 408return new HttpResponseMessage(HttpStatusCode.OK)

Telemetry\DashboardTelemetrySenderTests.cs (2)

84return Task.FromResult(new HttpResponseMessage(telemetryEnabledResponseStatusCode.Value) { Content = new StringContent(telemetryEnabledResponseBody ?? string.Empty) }); 92return Task.FromResult(new HttpResponseMessage(startTelemetryResponseStatusCode.Value));

Telemetry\DashboardTelemetryServiceTests.cs (5)

108return Task.FromResult(new HttpResponseMessage(HttpStatusCode.OK) 115return Task.FromResult(new HttpResponseMessage(HttpStatusCode.OK)); 119return Task.FromResult(new HttpResponseMessage(HttpStatusCode.OK)); 123return Task.FromResult(new HttpResponseMessage(HttpStatusCode.OK) 133return Task.FromResult(new HttpResponseMessage(HttpStatusCode.OK)

Dcp\TestKubernetesService.cs (2)

44Response = new HttpResponseMessageWrapper(new HttpResponseMessage { StatusCode = System.Net.HttpStatusCode.NotFound }, "Not found") 119Response = new HttpResponseMessageWrapper(new HttpResponseMessage { StatusCode = System.Net.HttpStatusCode.NotFound }, ex.Message)

WithHttpCommandTests.cs (1)

267return Task.FromResult(new HttpResponseMessage(statusCode));

ArcadeHttpMessageHandler.cs (2)

24return Task.FromResult(new HttpResponseMessage() 31return Task.FromResult(new HttpResponseMessage()

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));

VerbatimHttpHandler.cs (1)

86return new() { Content = new StringContent(_expectedOutput) };

VerbatimMultiPartHttpHandler.cs (1)

143return new() { Content = new StringContent(sentJsonOutput, Encoding.UTF8, "application/json") };

NoRemoteCallHandler.cs (1)

37var response = new HttpResponseMessage

NoRemoteCallNotSeekableHandler.cs (1)

40var response = new HttpResponseMessage

Latency\Internal\HttpClientLatencyLogEnricherTest.cs (2)

46using HttpResponseMessage httpResponseMessage = new(); 66using HttpResponseMessage httpResponseMessage = new();

Logging\HttpClientLoggerTest.cs (14)

Logging\HttpClientLoggingExtensionsTest.cs (2)

418var response = new HttpResponseMessage(HttpStatusCode.OK); 453? new HttpResponseMessage(HttpStatusCode.OK)

Logging\HttpHeadersReaderTest.cs (4)

24using var httpResponse = new HttpResponseMessage(); 42using var httpResponse = new HttpResponseMessage(); 145using var httpResponse = new HttpResponseMessage { Content = responseContent }; 178using var httpResponse = new HttpResponseMessage();

Logging\HttpRequestReaderTest.cs (7)

93using var httpResponseMessage = new HttpResponseMessage 155using var httpResponseMessage = new HttpResponseMessage 226using var httpResponseMessage = new HttpResponseMessage 302using var httpResponseMessage = new HttpResponseMessage 435using var httpResponseMessage = new HttpResponseMessage 504using var httpResponseMessage = new HttpResponseMessage 574using var httpResponseMessage = new HttpResponseMessage

Logging\HttpResponseBodyReaderTest.cs (9)

Logging\Internal\NoRemoteCallHandler.cs (1)

31var response = new HttpResponseMessage

NoRemoteCallHandler.cs (1)

18_response = new HttpResponseMessage

Hedging\HedgingTests.cs (1)

334_responses.Enqueue(new HttpResponseMessage(statusCode));

Hedging\HttpClientHedgingResiliencePredicatesTests.cs (1)

42using var response = new HttpResponseMessage(code);

Hedging\StandardHedgingTests.cs (2)

116using var response = new HttpResponseMessage(HttpStatusCode.OK); 361return new HttpResponseMessage(HttpStatusCode.OK);

Helpers\TestHandlerStub.cs (1)

17: this((_, _) => Task.FromResult(new HttpResponseMessage(statusCode)))

Internal\RequestMessageSnapshotStrategyTests.cs (1)

29return new ValueTask<HttpResponseMessage>(new HttpResponseMessage());

Internal\RetryAfterHelperTests.cs (4)

19using var response = new HttpResponseMessage(); 31using var response = new HttpResponseMessage(); 44using var response = new HttpResponseMessage(); 58using var response = new HttpResponseMessage();

Polly\HttpCircuitBreakerStrategyOptionsTests.cs (1)

59using var response = new HttpResponseMessage { StatusCode = statusCode };

Polly\HttpClientResiliencePredicatesTests.cs (1)

55var response = new HttpResponseMessage { StatusCode = statusCode };

Polly\HttpRetryStrategyOptionsExtensionsTests.cs (4)

50using var response = new HttpResponseMessage { RequestMessage = request }; 62using var response = new HttpResponseMessage { RequestMessage = request }; 86using var response = new HttpResponseMessage { RequestMessage = null }; 109using var response = new HttpResponseMessage { RequestMessage = request };

Polly\HttpRetryStrategyOptionsTests.cs (4)

58var response = new HttpResponseMessage { StatusCode = statusCode }; 83var response = new HttpResponseMessage { StatusCode = statusCode }; 102using var responseMessage = new HttpResponseMessage(); 130using var responseMessage = new HttpResponseMessage

Resilience\HttpClientBuilderExtensionsTests.Standard.cs (1)

245return Task.FromResult(new HttpResponseMessage(HttpStatusCode.InternalServerError));

Resilience\HttpResilienceMetricsEnricherTests.cs (1)

46using var response = new HttpResponseMessage(System.Net.HttpStatusCode.InternalServerError);

Resilience\ResilienceHandlerTest.cs (2)

112return Task.FromResult(new HttpResponseMessage { StatusCode = HttpStatusCode.Created }); 137return Task.FromResult(new HttpResponseMessage { StatusCode = HttpStatusCode.Created });

System\Net\Http\SocketsHttpHandler\Http2Stream.cs (1)

137_response = new HttpResponseMessage()

System\Net\Http\SocketsHttpHandler\Http3RequestStream.cs (1)

1094_response = new HttpResponseMessage()

System\Net\Http\SocketsHttpHandler\HttpConnection.cs (1)

665var response = new HttpResponseMessage() { RequestMessage = request, Content = new HttpConnectionResponseContent() };

System\Net\Http\WinHttpResponseParser.cs (1)

25var response = new HttpResponseMessage();

Commands\ExportCommand.cs (2)

263var response = await client.GetAsync(url, cancellationToken).ConfigureAwait(false); 294var response = await client.GetAsync(url, cancellationToken).ConfigureAwait(false);

Commands\TelemetryCommandHelpers.cs (2)

94public static bool HasJsonContentType(HttpResponseMessage response) 209var response = await client.GetAsync(url, cancellationToken).ConfigureAwait(false);

Commands\TelemetryLogsCommand.cs (2)

170var response = await client.GetAsync(url, cancellationToken); 196using var response = await client.GetAsync(url, HttpCompletionOption.ResponseHeadersRead, cancellationToken);

Commands\TelemetrySpansCommand.cs (2)

171var response = await client.GetAsync(url, cancellationToken); 197using var response = await client.GetAsync(url, HttpCompletionOption.ResponseHeadersRead, cancellationToken);

Commands\TelemetryTracesCommand.cs (2)

127var response = await client.GetAsync(url, cancellationToken); 208var response = await client.GetAsync(url, cancellationToken);

Mcp\Docs\DocsFetcher.cs (2)

52using var response = await _httpClient.SendAsync(request, cancellationToken).ConfigureAwait(false); 71using var retryResponse = await _httpClient.SendAsync(retryRequest, cancellationToken).ConfigureAwait(false);

Mcp\Tools\ListStructuredLogsTool.cs (1)

77var response = await client.GetAsync(url, cancellationToken).ConfigureAwait(false);

Mcp\Tools\ListTracesTool.cs (1)

77var response = await client.GetAsync(url, cancellationToken).ConfigureAwait(false);

Mcp\Tools\ListTraceStructuredLogsTool.cs (1)

77var response = await client.GetAsync(url, cancellationToken).ConfigureAwait(false);

Npm\SigstoreNpmProvenanceChecker.cs (1)

96var response = await httpClient.GetAsync(url, cancellationToken).ConfigureAwait(false);

Utils\CliDownloader.cs (1)

177using var response = await s_httpClient.GetAsync(url, HttpCompletionOption.ResponseHeadersRead, cts.Token);

Mcp\Docs\DocsFetcherTests.cs (13)

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(

Model\Assistant\ChatClientFactory.cs (1)

140using var httpResponse = await _httpClient.SendAsync(httpRequest, cancellationToken).ConfigureAwait(false);

Telemetry\DashboardTelemetrySender.cs (1)

142var response = await Client.GetAsync(TelemetryEndpoints.TelemetryEnabled).ConfigureAwait(false);

Telemetry\DashboardTelemetryService.cs (1)

357var httpResponseMessage = await client.PostAsJsonAsync(endpoint, request).ConfigureAwait(false);

Integration\FrontendBrowserTokenAuthTests.cs (6)

42var response = await client.GetAsync("/").DefaultTimeout(); 64var response1 = await client.GetAsync(DashboardUrls.LoginUrl(returnUrl: DashboardUrls.TracesUrl(), token: apiKey)).DefaultTimeout(); 71var response2 = await client.GetAsync(DashboardUrls.StructuredLogsUrl()).DefaultTimeout(); 95var response = await client.GetAsync(DashboardUrls.LoginUrl(returnUrl: DashboardUrls.TracesUrl(), token: apiKey)).DefaultTimeout(); 119var response = await client.GetAsync(DashboardUrls.LoginUrl(returnUrl: DashboardUrls.TracesUrl(), token: "Wrong!")).DefaultTimeout(); 144var response = await client.PostAsync("/api/validatetoken?token=" + requestToken, content: null).DefaultTimeout();

Integration\FrontendOpenIdConnectAuthTests.cs (2)

39var response = await client.GetAsync("/").DefaultTimeout(); 84var response = await client.GetAsync("/").DefaultTimeout();

Integration\HealthTests.cs (1)

33var response = await client.SendAsync(request).DefaultTimeout();

Integration\McpServiceTests.cs (12)

Integration\OtlpCorsHttpServiceTests.cs (5)

35var responseMessage = await httpClient.SendAsync(preflightRequest).DefaultTimeout(); 59var responseMessage1 = await httpClient.SendAsync(preflightRequest1).DefaultTimeout(); 73var responseMessage2 = await httpClient.SendAsync(preflightRequest2).DefaultTimeout(); 100var responseMessage = await httpClient.SendAsync(preflightRequest).DefaultTimeout(); 128var responseMessage = await httpClient.SendAsync(preflightRequest).DefaultTimeout();

Integration\OtlpHttpJsonTests.cs (8)

Integration\OtlpHttpServiceTests.cs (12)

Integration\ResponseCompressionTests.cs (2)

27var response = await client.SendAsync(request).DefaultTimeout(); 49var response = await client.SendAsync(request).DefaultTimeout();

Integration\StartupTests.cs (7)

343var response = await httpClient.SendAsync(request).DefaultTimeout(); 399var response = await browserHttpClient.SendAsync(request).DefaultTimeout(); 422var responseMessage = await mcpHttpClient.SendAsync(mcpRequest).DefaultTimeout(TestConstants.LongTimeoutDuration); 524var responseMessage = await httpClient.SendAsync(request).DefaultTimeout(); 831var response = await httpClient.GetAsync("/api/telemetry/spans").DefaultTimeout(); 987var response = await client.GetAsync("/").DefaultTimeout(); 1066var response = await client.SendAsync(request).DefaultTimeout();

Integration\TelemetryApiTests.cs (21)

Middleware\ValidateTokenMiddlewareTests.cs (6)

22var response = await host.GetTestClient().GetAsync("/login?t=test").DefaultTimeout(); 30var response = await host.GetTestClient().GetAsync("/login?t=test&returnUrl=/test").DefaultTimeout(); 38var response = await host.GetTestClient().GetAsync("/login?t=wrong").DefaultTimeout(); 46var response = await host.GetTestClient().GetAsync("/login?t=wrong&returnUrl=/test").DefaultTimeout(); 54var response = await host.GetTestClient().GetAsync("/login?t=token").DefaultTimeout(); 62var response = await host.GetTestClient().GetAsync("/login?t=token&returnUrl=/test").DefaultTimeout();

Telemetry\DashboardTelemetrySenderTests.cs (5)

82return Task.FromException<HttpResponseMessage>(new InvalidOperationException()); 90return Task.FromException<HttpResponseMessage>(new InvalidOperationException()); 151private readonly Func<HttpRequestMessage, CancellationToken, Task<HttpResponseMessage>> _value; 153public TestHttpMessageHandler(Func<HttpRequestMessage, CancellationToken, Task<HttpResponseMessage>> value) 158protected override Task<HttpResponseMessage> SendAsync(HttpRequestMessage request, CancellationToken cancellationToken)

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)

ApplicationModel\HttpCommandContext.cs (1)

79public required HttpResponseMessage Response { get; init; }

Dcp\DcpKubernetesClient.cs (3)

76var httpResponse = await SendRequest<object?>(url, HttpMethod.Get, customHeaders: null, body: null, cancellationToken).ConfigureAwait(false); 103var httpResponse = await SendRequestRaw(null, httpRequest, cancellationToken).ConfigureAwait(false); 133var httpResponse = await SendRequestRaw(content, httpRequest, cancellationToken).ConfigureAwait(false);

ResourceBuilderExtensions.cs (1)

2486var response = await httpClient.SendAsync(request, context.CancellationToken).ConfigureAwait(false);

AcrLoginService.cs (1)

109var response = await httpClient.PostAsync(exchangeUrl, content, cancellationToken).ConfigureAwait(false);

GitHubModelsHealthCheck.cs (2)

55using var response = await httpClient.SendAsync(request, cancellationToken).ConfigureAwait(false); 72private static async Task<HealthCheckResult> HandleErrorCode(HttpResponseMessage response, CancellationToken cancellationToken)

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)

PostgresFunctionalTests.cs (2)

91var response = await client.GetAsync(path); 176var response = await client.PostAsync("/api/connect", httpContent);

RedisFunctionalTests.cs (6)

92var response = await client.GetAsync(path); 159var response = await client.GetAsync("/api/databases", cts.Token); 190var testConnectionResponse = await client.GetAsync($"/api/databases/{db.Id}/connect", cts2.Token); 567var response = await httpClient.GetAsync("/api/settings", ct); 599var response = await client.PatchAsync(apiUrl, jsonContent, ct); 637var httpResponse = await client.GetAsync(redisCommanderUrl!);

SeqFunctionalTests.cs (2)

55var ingestResponse = await httpClient.PostAsync("/ingest/clef", content, token); 58var response = await httpClient.GetAsync("/api/events?filter=Username='johndoe'", token);

ContainerTunnelTests.cs (2)

38var response = await clientA.GetAsync("/servicea/").DefaultTimeout(TestConstants.DefaultOrchestratorTestTimeout); 78var response = await clientA.GetAsync("/servicea/").DefaultTimeout(TestConstants.DefaultOrchestratorTestTimeout);

WithHttpCommandTests.cs (1)

264protected override Task<HttpResponseMessage> SendAsync(HttpRequestMessage request, CancellationToken cancellationToken)

YarpFunctionalTests.cs (2)

54using var response200 = await httpClient.GetAsync("/aspnetapp"); 57using var response404 = await httpClient.GetAsync("/another");

AppHostTests.cs (1)

94HttpResponseMessage? response = null;

Infrastructure\DistributedApplicationExtensions.cs (2)

221using var checkResponse = await checkHttpClient.PostAsync("/ApplyDatabaseMigrations", emptyDbContextContent); 252using var response = await applyMigrationsHttpClient.PostAsync("/ApplyDatabaseMigrations", content);

ProjectSpecificTests.cs (1)

82var response = await AppHostTests.CreateHttpClientWithResilience(app, "funcapp").GetAsync("/api/injected-resources");

SeqHealthCheck.cs (1)

21using var response = await _client.GetAsync("/health", 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)

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;

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);

Program.cs (1)

15var response = await http.GetAsync("/");

NugetSearch\NugetToolSearchApiRequest.cs (1)

25HttpResponseMessage response = await httpClient.GetAsync(queryUrl, cancellation.Token);

Program.cs (1)

249using var response = await client.SendAsync(request, cancellationToken).ConfigureAwait(false);

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; }

Program.cs (1)

856using var response = await httpClient.SendAsync(request, cancellationToken).ConfigureAwait(false);

ServiceUtilHelper.cs (3)

576HttpResponseMessage response = httpClient.GetAsync(requestUri).GetAwaiter().GetResult(); 595HttpResponseMessage response = httpClient.GetAsync(requestUri).GetAwaiter().GetResult(); 614HttpResponseMessage response = await httpClient.GetAsync(requestUri);

StaticFileRegeneration\RegenerateThirdPartyNotices.cs (1)

74HttpResponseMessage response = await client.GetAsync(c.Url);

AuthorizationHandler.cs (1)

8protected override async Task<HttpResponseMessage> SendAsync(HttpRequestMessage request, CancellationToken cancellationToken)

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;}

OAuthHandler.cs (2)

222var response = await Backchannel.SendAsync(requestMessage, Context.RequestAborted); 232private static OAuthTokenResponse PrepareFailedOAuthTokenResponse(HttpResponseMessage response, string body)

Latency\ChecpointAcceptanceTests.cs (2)

103HttpResponseMessage? response = null; 127using var response = await host.GetTestServer().CreateClient().GetAsync("/Path");

Logging\AcceptanceTests.cs (19)

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);

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,

DownloadFile.cs (2)

157using (HttpResponseMessage response = await client.GetAsync(uri, HttpCompletionOption.ResponseHeadersRead, cancellationToken).ConfigureAwait(false)) 353private bool ShouldSkip(HttpResponseMessage response, FileInfo destinationFile)

Utils.cs (2)

31HttpResponseMessage httpResponse = await s_httpClient.SendAsync(httpRequest).ConfigureAwait(false); 64HttpResponseMessage httpResponse = await s_httpClient.GetAsync(address).ConfigureAwait(false);

src\DownloadFile.cs (1)

180var httpResponse = await httpClient.GetAsync(uri, _cancellationSource.Token).ConfigureAwait(false);

WebAssemblyHotReload.cs (1)

96var response = await client.GetAsync("/_framework/blazor-hotreload");

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);

VerbatimHttpHandler.cs (2)

44protected override async Task<HttpResponseMessage> SendAsync(HttpRequestMessage request, CancellationToken cancellationToken) 79using var response = await base.SendAsync(request, cancellationToken).ConfigureAwait(false);

VerbatimMultiPartHttpHandler.cs (1)

44protected override async Task<HttpResponseMessage> SendAsync(

ThrowUserAgentExceptionHandler.cs (1)

13protected override Task<HttpResponseMessage> SendAsync(HttpRequestMessage request, CancellationToken cancellationToken) =>

Readers\DocumentReaderConformanceTests.cs (4)

81using HttpResponseMessage response = await DownloadAsync(new(source)); 153protected static async Task<HttpResponseMessage> DownloadAsync(Uri uri) 157HttpResponseMessage response = await _httpClient.GetAsync(uri); 181using HttpResponseMessage response = await DownloadAsync(uri);

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)

Latency\Internal\HttpClientLatencyLogEnricher.cs (1)

39public void Enrich(IEnrichmentTagCollector collector, HttpRequestMessage? request, HttpResponseMessage? response, Exception? exception)

Latency\Internal\HttpLatencyMediator.cs (1)

29public void RecordEnd(ILatencyContext latencyContext, HttpResponseMessage? response = null)

Latency\Internal\HttpLatencyTelemetryHandler.cs (1)

45protected async override Task<HttpResponseMessage> SendAsync(HttpRequestMessage request, CancellationToken cancellationToken)

Logging\IHttpClientLogEnricher.cs (2)

20/// <param name="response"><see cref="HttpResponseMessage"/> object associated with the outgoing HTTP request.</param> 26void Enrich(IEnrichmentTagCollector collector, HttpRequestMessage request, HttpResponseMessage? response, Exception? exception);

Logging\Internal\HttpClientLogger.cs (6)

113HttpResponseMessage response, 121HttpResponseMessage? response, 130public void LogRequestStop(object? context, HttpRequestMessage request, HttpResponseMessage response, TimeSpan elapsed) 133public void LogRequestFailed(object? context, HttpRequestMessage request, HttpResponseMessage? response, Exception exception, TimeSpan elapsed) 153HttpResponseMessage? response, 219HttpRequestMessage request, HttpResponseMessage? response, Exception? exception)

Logging\Internal\HttpHeadersReader.cs (1)

55public void ReadResponseHeaders(HttpResponseMessage response, List<KeyValuePair<string, string>>? destination)

Logging\Internal\HttpRequestReader.cs (1)

100public async Task ReadResponseAsync(LogRecord logRecord, HttpResponseMessage response,

Logging\Internal\HttpResponseBodyReader.cs (3)

47public ValueTask<string> ReadAsync(HttpResponseMessage response, CancellationToken cancellationToken) 63private static async ValueTask<string> ReadFromStreamWithTimeoutAsync(HttpResponseMessage response, TimeSpan readTimeout, int readSizeLimit, CancellationToken cancellationToken) 91private static async ValueTask<string> ReadFromStreamAsync(HttpResponseMessage response, int readSizeLimit, CancellationToken cancellationToken)

Logging\Internal\IHttpHeadersReader.cs (2)

25/// <param name="response">An instance of <see cref="HttpResponseMessage"/> to read headers from.</param> 27void ReadResponseHeaders(HttpResponseMessage response, List<KeyValuePair<string, string>>? destination);

Logging\Internal\IHttpRequestReader.cs (3)

12/// Methods to read <see cref="HttpResponseMessage"/> or <see cref="HttpRequestMessage"/>. 17/// Reads <see cref="HttpResponseMessage"/>. 24Task ReadResponseAsync(LogRecord record, HttpResponseMessage response,

Logging\Internal\Log.cs (1)

14/// Logs <see cref="HttpRequestMessage"/>, <see cref="HttpResponseMessage"/> and the exceptions due to errors of request/response.

BenchEnricher.cs (1)

15public void Enrich(IEnrichmentTagCollector collector, HttpRequestMessage request, HttpResponseMessage? response, Exception? exception)

Benchmarks\HugeHttpCLientLoggingBenchmark.cs (32)

Benchmarks\MediumHttpClientLoggingBenchmark.cs (32)

Benchmarks\SmallHttpClientLoggingBenchmark.cs (32)

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

Latency\Internal\HttpClientLatencyLogEnricherTest.cs (2)

46using HttpResponseMessage httpResponseMessage = new(); 66using HttpResponseMessage httpResponseMessage = new();

Latency\Internal\HttpLatencyTelemetryHandlerTest.cs (2)

64var resp = new Mock<HttpResponseMessage>(); 66mockHandler.Protected().Setup<Task<HttpResponseMessage>>(

Logging\AcceptanceTests.cs (7)

40using var _ = await httpClient.GetAsync(_unreachableRequestUri); 71using var _ = await httpClient.GetAsync(_unreachableRequestUri); 197using var content = await httpClient 251var content = await firstClient!.SendRequest(httpRequestMessage); 363using var _ = await httpClient.SendAsync(httpRequestMessage); 432using var _ = await httpClient.SendAsync(httpRequestMessage); 690var content = await client.SendAsync(httpRequestMessage, HttpCompletionOption.ResponseHeadersRead);

Logging\HttpClientLoggerTest.cs (21)

Logging\HttpClientLoggingExtensionsTest.cs (5)

418var response = new HttpResponseMessage(HttpStatusCode.OK); 429using var response = await client.GetAsync("http://localhost/api"); 496private sealed class TestMessageHandler(Func<HttpRequestMessage, HttpResponseMessage> responseFactory) 499protected override Task<HttpResponseMessage> SendAsync(HttpRequestMessage request, CancellationToken cancellationToken) 509protected override async Task<HttpResponseMessage> SendAsync(HttpRequestMessage request, CancellationToken cancellationToken)

Logging\HttpHeadersReaderTest.cs (4)

24using var httpResponse = new HttpResponseMessage(); 42using var httpResponse = new HttpResponseMessage(); 145using var httpResponse = new HttpResponseMessage { Content = responseContent }; 178using var httpResponse = new HttpResponseMessage();

Logging\HttpRequestReaderTest.cs (7)

93using var httpResponseMessage = new HttpResponseMessage 155using var httpResponseMessage = new HttpResponseMessage 226using var httpResponseMessage = new HttpResponseMessage 302using var httpResponseMessage = new HttpResponseMessage 435using var httpResponseMessage = new HttpResponseMessage 504using var httpResponseMessage = new HttpResponseMessage 574using var httpResponseMessage = new HttpResponseMessage

Logging\HttpResponseBodyReaderTest.cs (9)

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);

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)

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)));

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()

Hedging\HedgingTests.cs (11)

37private readonly Queue<HttpResponseMessage> _responses = new(); 68foreach (var response in _responses) 107using var _ = await SendRequest(client, request, asynchronous, _cancellationTokenSource.Token); 127using var _ = await SendRequest(client, request, asynchronous, _cancellationTokenSource.Token); 200using var result = await SendRequest(client, request, asynchronous, _cancellationTokenSource.Token); 224using var _ = await SendRequest(client, request, asynchronous, _cancellationTokenSource.Token); 250using var _ = await SendRequest(client, request, asynchronous, _cancellationTokenSource.Token); 277using var _ = await SendRequest(client, request, asynchronous, _cancellationTokenSource.Token); 300using var result = await SendRequest(client, request, asynchronous, _cancellationTokenSource.Token); 308protected static Task<HttpResponseMessage> SendRequest( 348private Task<HttpResponseMessage> InnerHandlerFunction(HttpRequestMessage request, CancellationToken cancellationToken)

Hedging\HttpClientHedgingResiliencePredicatesTests.cs (6)

29Assert.True(HttpClientHedgingResiliencePredicates.IsTransient(Outcome.FromException<HttpResponseMessage>(new TimeoutRejectedException()))); 30Assert.True(HttpClientHedgingResiliencePredicates.IsTransient(Outcome.FromException<HttpResponseMessage>(new BrokenCircuitException()))); 31Assert.True(HttpClientHedgingResiliencePredicates.IsTransient(Outcome.FromException<HttpResponseMessage>(new HttpRequestException()))); 32Assert.False(HttpClientHedgingResiliencePredicates.IsTransient(Outcome.FromException<HttpResponseMessage>(new InvalidOperationException()))); 33Assert.False(HttpClientHedgingResiliencePredicates.IsTransient(Outcome.FromResult<HttpResponseMessage>(null))); 42using var response = new HttpResponseMessage(code);

Hedging\StandardHedgingTests.cs (13)

116using var response = new HttpResponseMessage(HttpStatusCode.OK); 118var args = new HedgingActionGeneratorArguments<HttpResponseMessage>(primary, secondary, 0, _ => Outcome.FromResultAsValueTask(response)); 177var primary = pipelineProvider.GetPipeline<HttpResponseMessage>(new HttpKey("clientId-standard-hedging", "instance")).GetPipelineDescriptor(); 186var inner = pipelineProvider.GetPipeline<HttpResponseMessage>(new HttpKey("clientId-standard-hedging-endpoint", "instance")).GetPipelineDescriptor(); 206var noPolicy = ResiliencePipeline<HttpResponseMessage>.Empty; 219provider.Setup(v => v.GetPipeline<HttpResponseMessage>(new HttpKey("clientId-standard-hedging", string.Empty))).Returns(noPolicy); 220provider.Setup(v => v.GetPipeline<HttpResponseMessage>(new HttpKey("clientId-standard-hedging-endpoint", customKey))).Returns(noPolicy); 226using var response = await SendRequest(client, request, asynchronous); 257using var _ = await SendRequest(client, firstRequest, asynchronous); 264using var __ = await SendRequest(client, secondRequest, asynchronous); 292using var _ = await SendRequest(client, request, asynchronous); 342using var _ = await SendRequest(client, request, asynchronous); 352protected override async Task<HttpResponseMessage> SendAsync(HttpRequestMessage request, CancellationToken cancellationToken)

Helpers\TestHandlerStub.cs (3)

14private readonly Func<HttpRequestMessage, CancellationToken, Task<HttpResponseMessage>> _handlerFunc; 21public TestHandlerStub(Func<HttpRequestMessage, CancellationToken, Task<HttpResponseMessage>> handlerFunc) 26protected override Task<HttpResponseMessage> SendAsync(HttpRequestMessage request, CancellationToken cancellationToken)

Internal\RequestMessageSnapshotStrategyTests.cs (1)

29return new ValueTask<HttpResponseMessage>(new HttpResponseMessage());

Internal\RetryAfterHelperTests.cs (4)

19using var response = new HttpResponseMessage(); 31using var response = new HttpResponseMessage(); 44using var response = new HttpResponseMessage(); 58using var response = new HttpResponseMessage();

Polly\HttpCircuitBreakerStrategyOptionsTests.cs (5)

59using var response = new HttpResponseMessage { StatusCode = statusCode }; 72private CircuitBreakerPredicateArguments<HttpResponseMessage> CreateArgs(Exception error) 73=> new(_context, Outcome.FromException<HttpResponseMessage>(error)); 75private CircuitBreakerPredicateArguments<HttpResponseMessage> CreateArgs(HttpResponseMessage response)

Polly\HttpClientResiliencePredicatesTests.cs (2)

39isTransientHttpException = HttpClientResiliencePredicates.IsTransient(Outcome.FromException<HttpResponseMessage>(ex)); 55var response = new HttpResponseMessage { StatusCode = statusCode };

Polly\HttpRetryStrategyOptionsExtensionsTests.cs (7)

50using var response = new HttpResponseMessage { RequestMessage = request }; 62using var response = new HttpResponseMessage { RequestMessage = request }; 86using var response = new HttpResponseMessage { RequestMessage = null }; 109using var response = new HttpResponseMessage { RequestMessage = request }; 114private static RetryPredicateArguments<HttpResponseMessage> CreatePredicateArguments(HttpResponseMessage? response, ResilienceContext? context = null) 116return new RetryPredicateArguments<HttpResponseMessage>(

Polly\HttpRetryStrategyOptionsTests.cs (10)

58var response = new HttpResponseMessage { StatusCode = statusCode }; 69var args = CreateArgs(Outcome.FromException<HttpResponseMessage>(exception), token ?? default); 83var response = new HttpResponseMessage { StatusCode = statusCode }; 93var args = CreateArgs(Outcome.FromException<HttpResponseMessage>(exception), token ?? default); 102using var responseMessage = new HttpResponseMessage(); 115Outcome.FromResult<HttpResponseMessage>(null), 121Outcome.FromException<HttpResponseMessage>(new InvalidOperationException()), 130using var responseMessage = new HttpResponseMessage 159private static RetryPredicateArguments<HttpResponseMessage> CreateArgs( 160Outcome<HttpResponseMessage> outcome,

Resilience\HttpClientBuilderExtensionsTests.BySelector.cs (2)

132.Setup(p => p.GetPipeline<HttpResponseMessage>(new HttpKey(pipelineName, expectedPipelineKey))) 133.Returns(ResiliencePipeline<HttpResponseMessage>.Empty);

Resilience\HttpClientBuilderExtensionsTests.Resilience.cs (10)

36Assert.Throws<ArgumentNullException>(() => builder.AddResilienceHandler("dummy", (Action<ResiliencePipelineBuilder<HttpResponseMessage>>)null!)); 37Assert.Throws<ArgumentNullException>(() => builder.AddResilienceHandler("dummy", (Action<ResiliencePipelineBuilder<HttpResponseMessage>, ResilienceHandlerContext>)null!)); 135using var response = await SendRequest(client, "https://dummy", asynchronous); 220.Setup(v => v.GetPipeline<HttpResponseMessage>(new HttpKey(expectedPipelineKey, "https://dummy1"))) 221.Returns(ResiliencePipeline<HttpResponseMessage>.Empty); 226.Setup(v => v.GetPipeline<HttpResponseMessage>(new HttpKey(expectedPipelineKey, string.Empty))) 227.Returns(ResiliencePipeline<HttpResponseMessage>.Empty); 260.Setup(v => v.GetPipeline<HttpResponseMessage>(new HttpKey(pipelineName, string.Empty))) 261.Returns(ResiliencePipeline<HttpResponseMessage>.Empty) 361private void ConfigureBuilder(ResiliencePipelineBuilder<HttpResponseMessage> builder) => builder.AddTimeout(TimeSpan.FromSeconds(1));

Resilience\HttpClientBuilderExtensionsTests.Standard.cs (4)

39private static Task<HttpResponseMessage> SendRequest(HttpClient client, string url, bool asynchronous) 165var descriptor = provider.GetPipeline<HttpResponseMessage>(new HttpKey("test-standard", string.Empty)).GetPipelineDescriptor(); 295private static ResiliencePipeline<HttpResponseMessage> GetPipeline(IServiceCollection services, string name) 299return provider.GetPipeline<HttpResponseMessage>(new HttpKey(name, string.Empty));

Resilience\HttpResilienceMetricsEnricherTests.cs (4)

34var context = new EnrichmentContext<HttpResponseMessage, string>(default, tags); 46using var response = new HttpResponseMessage(System.Net.HttpStatusCode.InternalServerError); 47var args = new TelemetryEventArguments<HttpResponseMessage, string>(default!, default!, default!, default!, Outcome.FromResult(response)); 48var context = new EnrichmentContext<HttpResponseMessage, string>(args, tags);

Resilience\ResilienceHandlerTest.cs (8)

28using var handler = new ResilienceHandler(ResiliencePipeline<HttpResponseMessage>.Empty); 66using var handler = new ResilienceHandler(_ => ResiliencePipeline<HttpResponseMessage>.Empty); 98using var handler = new ResilienceHandler(_ => ResiliencePipeline<HttpResponseMessage>.Empty); 115var response = await InvokeHandler(invoker, request, asynchronous); 129using var handler = new ResilienceHandler(_ => ResiliencePipeline<HttpResponseMessage>.Empty); 140var response = await InvokeHandler(invoker, request, asynchronous, source.Token); 153using var handler = new ResilienceHandler(_ => ResiliencePipeline<HttpResponseMessage>.Empty); 162private static Task<HttpResponseMessage> InvokeHandler(

ModelLoaders\UriModelLoader.cs (2)

110var resp = await client.SendAsync(headRequest); 143var resp = await client.GetAsync(_uri);

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)

StreamWrapper.cs (1)

95 var response = await client.GetAsync(uri, cancellationToken).ConfigureAwait(false);

DatasetUtil.cs (1)

210var response = await client.GetAsync(url).ConfigureAwait(false);

Utilities\ResourceManagerUtils.cs (1)

268var response = await httpClient.GetAsync(uri, ct).ConfigureAwait(false);

ImageClassificationBench.cs (3)

163var headerResponse = client.GetAsync(url, HttpCompletionOption.ResponseHeadersRead).Result; 171var response = client.GetAsync(url).Result; 180var response = client.GetAsync(url).Result;

Utils\Helpers.netcoreapp.cs (1)

31HttpResponseMessage response = client.Send(new HttpRequestMessage(HttpMethod.Get, url), HttpCompletionOption.ResponseHeadersRead);

test\Microsoft.ML.Tokenizers.Tests\Utils.cs (1)

21var response = await client.GetAsync(url);

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);

AmazonECRMessageHandler.cs (1)

20protected override async Task<HttpResponseMessage> SendAsync(HttpRequestMessage request, CancellationToken cancellationToken)

AuthHandshakeMessageHandler.cs (5)

74private static bool TryParseAuthenticationInfo(HttpResponseMessage msg, [NotNullWhen(true)] out string? scheme, out AuthInfo? bearerAuthInfo) 488using HttpResponseMessage postResponse = await base.SendAsync(postMessage, cancellationToken).ConfigureAwait(false); 532using var tokenResponse = await base.SendAsync(message, cancellationToken).ConfigureAwait(false); 572protected override async Task<HttpResponseMessage> SendAsync(HttpRequestMessage request, CancellationToken cancellationToken) 591var response = await base.SendAsync(request, cancellationToken).ConfigureAwait(false);

FallbackToHttpMessageHandler.cs (2)

30protected override async Task<HttpResponseMessage> SendAsync(HttpRequestMessage request, CancellationToken cancellationToken) 58HttpResponseMessage response = await base.SendAsync(request, cancellationToken).ConfigureAwait(false);

Registry\DefaultBlobOperations.cs (7)

33using HttpResponseMessage response = await _client.SendAsync(new HttpRequestMessage(HttpMethod.Head, new Uri(_baseUri, $"/v2/{repositoryName}/blobs/{digest}")), cancellationToken).ConfigureAwait(false); 46HttpResponseMessage response = await GetAsync(repositoryName, digest, cancellationToken).ConfigureAwait(false); 57HttpResponseMessage response = await GetAsync(repositoryName, digest, cancellationToken).ConfigureAwait(false); 62private async Task<HttpResponseMessage> GetAsync(string repositoryName, string digest, CancellationToken cancellationToken) 66HttpResponseMessage response = await _client.SendAsync(request, HttpCompletionOption.ResponseHeadersRead, cancellationToken).ConfigureAwait(false); 71_ => await LogAndThrowContainerHttpException<HttpResponseMessage>(response, cancellationToken).ConfigureAwait(false) 75private async Task<T> LogAndThrowContainerHttpException<T>(HttpResponseMessage response, CancellationToken cancellationToken)

Registry\DefaultBlobUploadOperations.cs (5)

31HttpResponseMessage finalizeResponse = await _client.PutAsync(putUri, null, cancellationToken).ConfigureAwait(false); 43public async Task<HttpResponseMessage> GetStatusAsync(Uri uploadUri, CancellationToken cancellationToken) 53HttpResponseMessage pushResponse = await _client.PostAsync(startUploadUri, content: null, cancellationToken).ConfigureAwait(false); 69HttpResponseMessage pushResponse = await _client.PostAsync(new Uri(_baseUri, $"/v2/{destinationRepository}/blobs/uploads/?mount={digest}&from={sourceRepository}"), content: null, cancellationToken).ConfigureAwait(false); 110using HttpResponseMessage patchResponse = await _client.SendAsync(patchMessage, cancellationToken).ConfigureAwait(false);

Registry\DefaultManifestOperations.cs (5)

27public async Task<HttpResponseMessage> GetAsync(string repositoryName, string reference, CancellationToken cancellationToken) 31HttpResponseMessage response = await _client.SendAsync(request, cancellationToken).ConfigureAwait(false); 37_ => await LogAndThrowContainerHttpException<HttpResponseMessage>(response, cancellationToken).ConfigureAwait(false) 46HttpResponseMessage putResponse = await _client.PutAsync(new Uri(_baseUri, $"/v2/{repositoryName}/manifests/{reference}"), manifestUploadContent, cancellationToken).ConfigureAwait(false); 55private async Task<T> LogAndThrowContainerHttpException<T>(HttpResponseMessage response, CancellationToken cancellationToken)

Registry\HttpExtensions.cs (2)

31public static Uri GetNextLocation(this HttpResponseMessage response) 67internal static async Task LogHttpResponseAsync(this HttpResponseMessage response, ILogger logger, CancellationToken cancellationToken)

Registry\IBlobUploadOperations.cs (1)

22public Task<HttpResponseMessage> GetStatusAsync(Uri uploadUri, CancellationToken cancellationToken);

Registry\IManifestOperations.cs (1)

14public Task<HttpResponseMessage> GetAsync(string repositoryName, string reference, CancellationToken cancellationToken);

Registry\Registry.cs (3)

193using HttpResponseMessage initialManifestResponse = await _registryAPI.Manifest.GetAsync(repositoryName, reference, cancellationToken).ConfigureAwait(false); 241using HttpResponseMessage initialManifestResponse = await _registryAPI.Manifest.GetAsync(repositoryName, reference, cancellationToken).ConfigureAwait(false); 389using HttpResponseMessage manifestResponse = await _registryAPI.Manifest.GetAsync(repositoryName, manifestDigest, cancellationToken).ConfigureAwait(false);

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);

Providers\NuGetMetadataSearchProvider.cs (2)

185using HttpResponseMessage response = await client.GetAsync(searchMetadataUri, cancellationToken).ConfigureAwait(false); 236private string GetResponseDetails(HttpResponseMessage response)

netstandard.cs (1)

1132[assembly: System.Runtime.CompilerServices.TypeForwardedTo(typeof(System.Net.Http.HttpResponseMessage))]

Signing\Timestamp\Rfc3161TimestampRequestNetstandard21Wrapper.cs (1)

59using (HttpResponseMessage httpResponse = await HttpClient.PostAsync(timestampUri, content))

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)

251internal async Task<IEnumerable<PackageSearchMetadata>> ProcessHttpStreamTakeCountedItemAsync(HttpResponseMessage httpInitialResponse, int take, CancellationToken token) 261private async Task<V3SearchResults> ProcessHttpStreamWithoutBufferingAsync(HttpResponseMessage httpInitialResponse, uint take, CancellationToken token) 279private static async Task<V3SearchResults> ProcessHttpStreamWithStjAsync(HttpResponseMessage httpInitialResponse, uint take, CancellationToken token) 296private static async Task<V3SearchResults> ProcessHttpStreamWithNsjAsync(HttpResponseMessage httpInitialResponse, uint take, CancellationToken token)

Resources\PackageUpdateResource.cs (1)

534private static HttpStatusCode? EnsureSuccessStatusCode(HttpResponseMessage response, HttpStatusCode? codeNotToThrow, ILogger logger)

DistributedApplicationPipelineExtensions.cs (1)

156var response = await httpClient.PostAsync(kuduUrl, content, cancellationToken).ConfigureAwait(false);

Program.cs (1)

157var response = await client.GetAsync(url);

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)

System\Net\Http\HttpClientHandler.cs (2)

358protected internal override HttpResponseMessage Send(HttpRequestMessage request, CancellationToken cancellationToken) 368protected internal override Task<HttpResponseMessage> SendAsync(HttpRequestMessage request, CancellationToken cancellationToken)

System\Net\Http\HttpMessageHandler.cs (2)

22protected internal virtual HttpResponseMessage Send(HttpRequestMessage request, CancellationToken cancellationToken) 27protected internal abstract Task<HttpResponseMessage> SendAsync(HttpRequestMessage request, CancellationToken cancellationToken);

System\Net\Http\HttpMessageInvoker.cs (5)

35public virtual HttpResponseMessage Send(HttpRequestMessage request, CancellationToken cancellationToken) 45HttpResponseMessage? response = null; 67public virtual Task<HttpResponseMessage> SendAsync(HttpRequestMessage request, CancellationToken cancellationToken) 80static async Task<HttpResponseMessage> SendAsyncWithTelemetry(HttpMessageHandler handler, HttpRequestMessage request, CancellationToken cancellationToken) 84HttpResponseMessage? response = null;

System\Net\Http\HttpResponseMessage.cs (1)

161public HttpResponseMessage EnsureSuccessStatusCode()

System\Net\Http\HttpTelemetry.cs (1)

63public void RequestStop(HttpResponseMessage? response)

System\Net\Http\MessageProcessingHandler.cs (10)

27protected abstract HttpResponseMessage ProcessResponse(HttpResponseMessage response, 30protected internal sealed override HttpResponseMessage Send(HttpRequestMessage request, 37HttpResponseMessage response = base.Send(newRequestMessage, cancellationToken); 38HttpResponseMessage newResponseMessage = ProcessResponse(response, cancellationToken); 42protected internal sealed override Task<HttpResponseMessage> SendAsync(HttpRequestMessage request, 56Task<HttpResponseMessage> sendAsyncTask = base.SendAsync(newRequestMessage, cancellationToken); 86HttpResponseMessage responseMessage = self.ProcessResponse(task.Result, token); 118TaskCompletionSource<HttpResponseMessage> tcs, OperationCanceledException e) 136private sealed class SendState : TaskCompletionSource<HttpResponseMessage>

System\Net\Http\Metrics\HttpMetricsEnrichmentContext.cs (3)

26private HttpResponseMessage? _response; 46public HttpResponseMessage? Response => _response; 102HttpResponseMessage? response,

System\Net\Http\Metrics\MetricsHandler.cs (6)

41internal override ValueTask<HttpResponseMessage> SendAsync(HttpRequestMessage request, bool async, CancellationToken cancellationToken) 50new ValueTask<HttpResponseMessage>(_innerHandler.SendAsync(request, cancellationToken)) : 51new ValueTask<HttpResponseMessage>(_innerHandler.Send(request, cancellationToken)); 55private async ValueTask<HttpResponseMessage> SendAsyncWithMetrics(HttpRequestMessage request, bool async, CancellationToken cancellationToken) 60HttpResponseMessage? response = null; 104private void RequestStop(HttpRequestMessage request, HttpResponseMessage? response, Exception? exception, long startTimestamp, bool recordCurrentRequests)

System\Net\Http\SocketsHttpHandler\AuthenticationHelper.cs (10)

System\Net\Http\SocketsHttpHandler\AuthenticationHelper.NtAuth.cs (6)

21private static Task<HttpResponseMessage> InnerSendAsync(HttpRequestMessage request, bool async, bool isProxyAuth, HttpConnectionPool pool, HttpConnection connection, CancellationToken cancellationToken) 28private static bool ProxySupportsConnectionAuth(HttpResponseMessage response) 46private static async Task<HttpResponseMessage> SendWithNtAuthAsync(HttpRequestMessage request, Uri authUri, bool async, ICredentials credentials, TokenImpersonationLevel impersonationLevel, bool isProxyAuth, HttpConnection connection, HttpConnectionPool connectionPool, CancellationToken cancellationToken) 48HttpResponseMessage response = await InnerSendAsync(request, async, isProxyAuth, connectionPool, connection, cancellationToken).ConfigureAwait(false); 205public static Task<HttpResponseMessage> SendWithNtProxyAuthAsync(HttpRequestMessage request, Uri proxyUri, bool async, ICredentials proxyCredentials, TokenImpersonationLevel impersonationLevel, HttpConnection connection, HttpConnectionPool connectionPool, CancellationToken cancellationToken) 210public static Task<HttpResponseMessage> SendWithNtConnectionAuthAsync(HttpRequestMessage request, bool async, ICredentials credentials, TokenImpersonationLevel impersonationLevel, HttpConnection connection, HttpConnectionPool connectionPool, CancellationToken cancellationToken)

System\Net\Http\SocketsHttpHandler\ChunkedEncodingReadStream.cs (2)

21private readonly HttpResponseMessage _response; 23public ChunkedEncodingReadStream(HttpConnection connection, HttpResponseMessage response) : base(connection)

System\Net\Http\SocketsHttpHandler\ConnectionPool\HttpConnectionPool.cs (7)

346public ValueTask<HttpResponseMessage> SendAsync(HttpRequestMessage request, bool async, bool doRequestAuth, CancellationToken cancellationToken) 365public ValueTask<HttpResponseMessage> SendWithProxyAuthAsync(HttpRequestMessage request, bool async, bool doRequestAuth, CancellationToken cancellationToken) 375private Task<HttpResponseMessage> SendWithNtConnectionAuthAsync(HttpConnection connection, HttpRequestMessage request, bool async, bool doRequestAuth, CancellationToken cancellationToken) 385public Task<HttpResponseMessage> SendWithNtProxyAuthAsync(HttpConnection connection, HttpRequestMessage request, bool async, CancellationToken cancellationToken) 395public async ValueTask<HttpResponseMessage> SendWithVersionDetectionAndRetryAsync(HttpRequestMessage request, bool async, bool doRequestAuth, CancellationToken cancellationToken) 407HttpResponseMessage? response = null; 789HttpResponseMessage tunnelResponse = await _poolManager.SendProxyConnectAsync(tunnelRequest, _proxyUri!, async, cancellationToken).ConfigureAwait(false);

System\Net\Http\SocketsHttpHandler\ConnectionPool\HttpConnectionPool.Http3.cs (3)

63private async ValueTask<HttpResponseMessage?> TrySendUsingHttp3Async(HttpRequestMessage request, CancellationToken cancellationToken) 107HttpResponseMessage response = await connection.SendAsync(request, waitForConnectionActivity, streamAvailable, cancellationToken).ConfigureAwait(false); 636private void ProcessAltSvc(HttpResponseMessage response)

System\Net\Http\SocketsHttpHandler\CookieHelper.cs (1)

12public static void ProcessReceivedCookies(HttpResponseMessage response, CookieContainer cookieContainer)

System\Net\Http\SocketsHttpHandler\DecompressionHandler.cs (2)

66internal override async ValueTask<HttpResponseMessage> SendAsync(HttpRequestMessage request, bool async, CancellationToken cancellationToken) 98HttpResponseMessage response = await _innerHandler.SendAsync(request, async, cancellationToken).ConfigureAwait(false);

System\Net\Http\SocketsHttpHandler\Http2Connection.cs (2)

2000public async Task<HttpResponseMessage> SendAsync(HttpRequestMessage request, bool async, CancellationToken cancellationToken) 2067HttpResponseMessage response = http2Stream.GetAndClearResponse();

System\Net\Http\SocketsHttpHandler\Http2Stream.cs (9)

System\Net\Http\SocketsHttpHandler\Http3Connection.cs (2)

264public async Task<HttpResponseMessage> SendAsync(HttpRequestMessage request, WaitForHttp3ConnectionActivity waitForConnectionActivity, bool streamAvailable, CancellationToken cancellationToken) 334Task<HttpResponseMessage> responseTask = requestStream.SendAsync(cancellationToken);

System\Net\Http\SocketsHttpHandler\Http3RequestStream.cs (8)

System\Net\Http\SocketsHttpHandler\HttpConnection.cs (8)

532public async Task<HttpResponseMessage> SendAsync(HttpRequestMessage request, bool async, CancellationToken cancellationToken) 665var response = new HttpResponseMessage() { RequestMessage = request, Content = new HttpConnectionResponseContent() }; 1029private bool ParseStatusLine(HttpResponseMessage response) 1058private static void ParseStatusLineCore(Span<byte> line, HttpResponseMessage response) 1131private bool ParseHeaders(HttpResponseMessage? response, bool isFromTrailer) 1150private (bool finished, int bytesConsumed) ParseHeadersCore(Span<byte> buffer, HttpResponseMessage? response, bool isFromTrailer) 1229private void AddResponseHeader(ReadOnlySpan<byte> name, ReadOnlySpan<byte> value, HttpResponseMessage response, bool isFromTrailer) 2074public async ValueTask DrainResponseAsync(HttpResponseMessage response, CancellationToken cancellationToken)

System\Net\Http\SocketsHttpHandler\HttpConnectionHandler.cs (1)

20internal override ValueTask<HttpResponseMessage> SendAsync(HttpRequestMessage request, bool async, CancellationToken cancellationToken)

System\Net\Http\SocketsHttpHandler\HttpConnectionPoolManager.cs (4)

332public ValueTask<HttpResponseMessage> SendAsyncCore(HttpRequestMessage request, Uri? proxyUri, bool async, bool doRequestAuth, bool isProxyConnect, CancellationToken cancellationToken) 371public ValueTask<HttpResponseMessage> SendProxyConnectAsync(HttpRequestMessage request, Uri proxyUri, bool async, CancellationToken cancellationToken) 376public ValueTask<HttpResponseMessage> SendAsync(HttpRequestMessage request, bool async, bool doRequestAuth, CancellationToken cancellationToken) 429private async ValueTask<HttpResponseMessage> SendAsyncMultiProxy(HttpRequestMessage request, bool async, bool doRequestAuth, MultiProxy multiProxy, Uri? firstProxy, CancellationToken cancellationToken)

System\Net\Http\SocketsHttpHandler\HttpMessageHandlerStage.cs (4)

11protected internal sealed override HttpResponseMessage Send(HttpRequestMessage request, 14ValueTask<HttpResponseMessage> sendTask = SendAsync(request, async: false, cancellationToken); 20protected internal sealed override Task<HttpResponseMessage> SendAsync(HttpRequestMessage request, CancellationToken cancellationToken) => 23internal abstract ValueTask<HttpResponseMessage> SendAsync(HttpRequestMessage request, bool async, CancellationToken cancellationToken);

System\Net\Http\SocketsHttpHandler\RedirectHandler.cs (3)

27internal override async ValueTask<HttpResponseMessage> SendAsync(HttpRequestMessage request, bool async, CancellationToken cancellationToken) 29HttpResponseMessage response = await _innerHandler.SendAsync(request, async, cancellationToken).ConfigureAwait(false); 93private Uri? GetUriForRedirect(Uri requestUri, HttpResponseMessage response)

System\Net\Http\SocketsHttpHandler\SocketsHttpHandler.cs (5)

574protected internal override HttpResponseMessage Send(HttpRequestMessage request, 605protected internal override Task<HttpResponseMessage> SendAsync(HttpRequestMessage request, CancellationToken cancellationToken) 613return Task.FromCanceled<HttpResponseMessage>(cancellationToken); 619return Task.FromException<HttpResponseMessage>(error); 629async Task<HttpResponseMessage> CreateHandlerAndSendAsync(HttpRequestMessage request, CancellationToken cancellationToken)

System\Net\Http\Json\HttpClientJsonExtensions.cs (9)

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.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\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\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; }

Program.cs (1)

21var response = await client.GetAsync("/api/weatherforecast");