Repeater

.cs

public static class Repeater
{
	public static async Task DoInfinityAsync(Action action, TimeSpan interval, CancellationToken cancellationToken)
	{
		while (!cancellationToken.IsCancellationRequested)
		{
			try
			{
				action();
				await Task.Delay(interval, cancellationToken);
			}
			catch (TaskCanceledException)
			{
				return;
			}
			catch (Exception ex)
			{
				//log
				return;
			}
		}
	}

	/// <exception cref="AggregateException"/>
	public static async Task DoAsync(Action action, TimeSpan retryInterval, int retryCount = 3)
	{
		await DoAsync(() =>
		{
			action();
			return default(object);
		}, retryInterval, retryCount);
	}

	/// <exception cref="AggregateException"/>
	public static async Task<T> DoAsync<T>(Func<T> action, TimeSpan retryInterval, int retryCount = 3)
	{
		var exceptions = new List<Exception>();

		for (int retry = 0; retry < retryCount; retry++)
		{
			try
			{
				if (retry > 0)
					await Task.Delay(retryInterval);
				return action();
			}
			catch (Exception ex)
			{
				exceptions.Add(ex);
			}
		}

		throw new AggregateException(exceptions);
	}
}