delayutil

Author: soenneker

src/BackgroundQueue.cs

@@ -9,6 +9,7 @@
 using Soenneker.Extensions.Task;
 using Soenneker.Extensions.ValueTask;
 using Soenneker.Utils.BackgroundQueue.Abstract;
+using Soenneker.Utils.Delay;
 
 namespace Soenneker.Utils.BackgroundQueue;
 
@@ -115,10 +116,10 @@ public async ValueTask WaitUntilEmpty(CancellationToken cancellationToken = defa
             {
                 if (_log)
                 {
-                    _logger.LogDebug("Delaying for {ms}ms (Background queue emptying...)...", delayMs);
+                    _logger.LogDebug("Delaying for {ms}ms (Background queue emptying)...", delayMs);
                 }
 
-                await Task.Delay(delayMs, cancellationToken).NoSync();
+                await DelayUtil.Delay(delayMs, null, cancellationToken).NoSync();
             }
             else
             {

src/Soenneker.Utils.BackgroundQueue.csproj

@@ -43,5 +43,6 @@
         <PackageReference Include="Soenneker.Extensions.MethodInfo" Version="3.0.345" />
         <PackageReference Include="Soenneker.Extensions.Task" Version="3.0.102" />
         <PackageReference Include="Soenneker.Extensions.ValueTask" Version="3.0.92" />
+        <PackageReference Include="Soenneker.Utils.Delay" Version="3.0.20" />
     </ItemGroup>
 </Project>

test/Soenneker.Utils.BackgroundQueue.Tests/BackgroundQueueTests.cs

@@ -1,8 +1,8 @@
 using System.Threading.Tasks;
 using Soenneker.Utils.BackgroundQueue.Abstract;
+using Soenneker.Utils.Delay;
 using Xunit;
 
-
 namespace Soenneker.Utils.BackgroundQueue.Tests;
 
 [Collection("Collection")]
@@ -32,7 +32,7 @@ public async Task WaitOnQueueToEmpty_should_complete_with_Task()
 
         await WaitOnQueueToEmpty(CancellationToken);
 
-        await Task.Delay(500, CancellationToken);
+        await DelayUtil.Delay(500, null, CancellationToken);
     }
 
     [Fact]
@@ -42,6 +42,6 @@ public async Task WaitOnQueueToEmpty_should_complete_with_ValueTask()
 
         await WaitOnQueueToEmpty(CancellationToken);
 
-        await Task.Delay(500, CancellationToken);
+        await DelayUtil.Delay(500, null, CancellationToken);
     }
-}
+}