👁 Image
Soenneker.Utils.RateLimiting.Factory 4.0.1102

👁 alternate text is missing from this package README image
👁 alternate text is missing from this package README image
👁 alternate text is missing from this package README image
👁 alternate text is missing from this package README image

👁 alternate text is missing from this package README image
Soenneker.Utils.RateLimiting.Factory

An async thread-safe singleton dictionary for , designed to manage the rate at which tasks are executed.

Installation

dotnet add package Soenneker.Utils.RateLimiting.Factory

Usage

1. Register IRateLimitingFactory within DI (Program.cs).

public static async Task Main(string[] args)
{
 ...
 builder.Services.AddRateLimitingFactoryAsSingleton();
}

2. Inject IRateLimitingFactory, and retrieve a RateLimitingFactory.

Example:

public class TestClass
{
 IRateLimitingFactory _factory;

 public TestClass(IRateLimitingFactory factory)
 {
 _factory = factory;
 }

 public async ValueTask ExecuteTasks()
 {
 RateLimitingExecutor rateLimitingExecutor = await _factory.Get("test", TimeSpan.FromSeconds(2));

 for (int i = 0; i < 5; i++)
 {
 await rateLimitingExecutor.Execute(async ct =>
 {
 Logger.LogInformation($"Executing Task {i + 1} at {DateTime.Now:HH:mm:ss}");

 await Task.Delay(100, ct); // Simulate some work
 });
 }
 }
}

Console Output

Executing Task 1 at 14:00:00
Executing Task 2 at 14:00:02
Executing Task 3 at 14:00:04
Executing Task 4 at 14:00:06
Executing Task 5 at 14:00:08