misc cancellationtoken

Author: soenneker

test/Soenneker.Utils.BackgroundQueue.Tests/Abstract/IFixturedUnitTest.cs

@@ -1,4 +1,5 @@
-using System.Threading.Tasks;
+using System.Threading;
+using System.Threading.Tasks;
 using Soenneker.Tests.Unit;
 using Xunit;
 
@@ -25,5 +26,5 @@ public interface IFixturedUnitTest : IAsyncLifetime
     /// <summary>
     /// Checks the background queue to see if it's empty, and loops until it is
     /// </summary>
-    ValueTask WaitOnQueueToEmpty();
+    ValueTask WaitOnQueueToEmpty(CancellationToken cancellationToken = default);
 }

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

@@ -28,20 +28,20 @@ private async ValueTask TestValueTask()
     [Fact]
     public async Task WaitOnQueueToEmpty_should_complete_with_Task()
     {
-        await _util.QueueTask(_ => TestTask());
+        await _util.QueueTask(_ => TestTask(), CancellationToken);
 
-        await WaitOnQueueToEmpty();
+        await WaitOnQueueToEmpty(CancellationToken);
 
-        await Task.Delay(500);
+        await Task.Delay(500, CancellationToken);
     }
 
     [Fact]
     public async Task WaitOnQueueToEmpty_should_complete_with_ValueTask()
     {
-        await _util.QueueValueTask(_ => TestValueTask());
+        await _util.QueueValueTask(_ => TestValueTask(), CancellationToken);
 
-        await WaitOnQueueToEmpty();
+        await WaitOnQueueToEmpty(CancellationToken);
 
-        await Task.Delay(500);
+        await Task.Delay(500, CancellationToken);
     }
 }

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

@@ -71,15 +71,15 @@ public void CreateScope()
         Scope = Fixture.ServiceProvider.CreateAsyncScope();
     }
 
-    public async ValueTask WaitOnQueueToEmpty()
+    public async ValueTask WaitOnQueueToEmpty(CancellationToken cancellationToken = default)
     {
         const int delayMs = 500;
 
         bool isProcessing;
 
         do
         {
-            isProcessing = await _queueInformationUtil.Value.IsProcessing().NoSync();
+            isProcessing = await _queueInformationUtil.Value.IsProcessing(cancellationToken).NoSync();
 
             if (isProcessing)
             {