fix

Author: st0o0

src/TurboHTTP.Tests/AltSvc/AltSvcCacheSpec.cs

@@ -213,7 +213,7 @@ public async Task TryGetHttp3_should_survive_concurrent_store_and_eviction_under
             {
                 cache.Store("example.com", [CreateH3Entry(maxAge: 60)]);
             }
-        });
+        }, TestContext.Current.CancellationToken);
 
         var evictTask = Task.Run(() =>
         {
@@ -222,7 +222,7 @@ public async Task TryGetHttp3_should_survive_concurrent_store_and_eviction_under
             {
                 cache.TryGetHttp3("example.com", out _, afterExpiry);
             }
-        });
+        }, TestContext.Current.CancellationToken);
 
         await Task.WhenAll(storeTask, evictTask);
 

src/TurboHTTP.Tests/Internal/PendingRequestSpec.cs

@@ -134,7 +134,7 @@ public async Task CancelPendingRequests_pattern_should_survive_concurrent_add_an
                 pendingTcs.TryAdd(pr, 0);
                 Interlocked.Increment(ref addCount);
             }
-        });
+        }, TestContext.Current.CancellationToken);
 
         var cancelTask = Task.Run(() =>
         {
@@ -151,7 +151,7 @@ public async Task CancelPendingRequests_pattern_should_survive_concurrent_add_an
                     }
                 }
             }
-        });
+        }, TestContext.Current.CancellationToken);
 
         await Task.WhenAll(addTask, cancelTask);
 

src/TurboHTTP.Tests/Transport/GenerationCounterSpec.cs

@@ -13,44 +13,6 @@ namespace TurboHTTP.Tests.Transport;
 /// </summary>
 public sealed class GenerationCounterSpec
 {
-    [Fact(Timeout = 5000)]
-    public void Stale_gen_should_cause_batch_to_be_discarded()
-    {
-        var currentGen = 5;
-        var batchGen = 3;
-
-        var processed = false;
-        var discarded = false;
-
-        if (batchGen == currentGen)
-        {
-            processed = true;
-        }
-        else
-        {
-            discarded = true;
-        }
-
-        Assert.False(processed);
-        Assert.True(discarded);
-    }
-
-    [Fact(Timeout = 5000)]
-    public void Current_gen_should_cause_batch_to_be_processed()
-    {
-        var currentGen = 5;
-        var batchGen = 5;
-
-        var processed = false;
-
-        if (batchGen == currentGen)
-        {
-            processed = true;
-        }
-
-        Assert.True(processed);
-    }
-
     [Fact(Timeout = 5000)]
     public async Task Pump_should_drain_and_exit_when_cts_canceled()
     {
@@ -95,7 +57,7 @@ public async Task Pump_should_drain_and_exit_when_cts_canceled()
                 // Actor cancels after first item is processed
                 cts.Cancel();
             }
-        });
+        }, TestContext.Current.CancellationToken);
 
         await pumpTask;
 
@@ -138,7 +100,7 @@ public async Task Pump_should_process_all_items_when_not_canceled()
                     Interlocked.Increment(ref processedCount);
                 }
             }
-        });
+        }, TestContext.Current.CancellationToken);
 
         await pumpTask;
 
@@ -183,7 +145,7 @@ await Task.Run(() =>
                     Interlocked.Increment(ref discardedCount);
                 }
             }
-        });
+        }, TestContext.Current.CancellationToken);
 
         Assert.True(processedCount > 0, "At least some batches should match current gen");
         Assert.True(discardedCount > 0, "At least some batches should be stale");