using System;

using System.Net;

using System.Net.Http;

using Microsoft.Extensions.DependencyInjection;

using System.Threading.Tasks;

using Refit;

using Polly;

using Polly.Retry;

public class Program

{

    public static async Task Main()

    {

        await RefitExample();

    }

    private static ValueTask<bool> HandleTransientHttpError(Outcome<HttpResponseMessage> outcome)

    => outcome switch

    {

        { Exception: HttpRequestException } => PredicateResult.True(),

        { Result.StatusCode: HttpStatusCode.RequestTimeout } => PredicateResult.True(),

        { Result.StatusCode: >= HttpStatusCode.InternalServerError } => PredicateResult.True(),

        _ => PredicateResult.False()

    };

​

    private static RetryStrategyOptions<HttpResponseMessage> GetRetryOptions()

    => new()

    {

        ShouldHandle = args => HandleTransientHttpError(args.Outcome),

        MaxRetryAttempts = 3,

        BackoffType = DelayBackoffType.Exponential,

        Delay = TimeSpan.FromSeconds(2)

    };

    public static async Task RefitExample()

    {

        #region http-client-integrations-refit

        ServiceCollection services = new();

        services.AddRefitClient<IHttpStatusApi>()

                .ConfigureHttpClient(client => client.BaseAddress = new Uri("https://httpstat.us/"))

                .AddResilienceHandler("refit_based_pipeline",

                    builder => builder.AddRetry(GetRetryOptions()));

​

        var provider = services.BuildServiceProvider();

        var apiClient = provider.GetRequiredService<IHttpStatusApi>();

​

        var response = await apiClient.GetRequestTimeoutEndpoinAsync();

        #endregion

    }

}

​

public interface IHttpStatusApi

{

    [Get("/408")]

    Task<HttpResponseMessage> GetRequestTimeoutEndpoinAsync();

}

​