-
Notifications
You must be signed in to change notification settings - Fork 24
/
RetryService.cs
45 lines (39 loc) · 1.21 KB
/
RetryService.cs
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
using System;
using System.Linq;
using System.Threading.Tasks;
namespace Crowdin.Api.Core.Resilience
{
public interface IRetryService
{
Task<T> ExecuteRequestAsync<T>(Func<Task<T>> func);
}
public class RetryService : IRetryService
{
private readonly RetryConfiguration _configuration;
public RetryService(RetryConfiguration configuration)
{
_configuration = configuration;
}
public async Task<T> ExecuteRequestAsync<T>(Func<Task<T>> func)
{
for (var i = 0; i <= _configuration.RetriesCount; i++)
{
try
{
return await func();
}
catch (Exception exception)
{
bool skip = _configuration.SkipRetryConditions.Any(condition => condition(exception));
if (skip || i == _configuration.RetriesCount)
{
throw;
}
await Task.Delay(_configuration.WaitIntervalMilliseconds);
}
}
throw new Exception("Wrong retry configuration. Failed to get value");
}
}
}