test(quic): update specs for pooling, batching and migration timer changes

Author: st0o0

src/Servus.Akka.Tests/Transport/Quic/Client/QuicConnectionLeaseSpec.cs

@@ -182,35 +182,34 @@ public void ActiveStreams_should_reflect_busy_idle_balance()
     }
 
     [Fact(Timeout = 5000)]
-    public void LastActivity_should_update_on_MarkBusy()
+    public void LastActivityTicks_should_update_on_MarkBusy()
     {
         var handle = CreateTestHandle();
         var lease = new QuicConnectionLease(handle, 10);
 
-        var initialActivity = lease.LastActivity;
+        var initialTicks = lease.LastActivityTicks;
 
-        // Wait a bit to ensure time difference
         Thread.Sleep(10);
 
         lease.MarkBusy();
-        var afterBusy = lease.LastActivity;
+        var afterBusy = lease.LastActivityTicks;
 
-        Assert.True(afterBusy > initialActivity);
+        Assert.True(afterBusy > initialTicks);
     }
 
     [Fact(Timeout = 5000)]
-    public void LastActivity_should_update_on_MarkIdle()
+    public void LastActivityTicks_should_update_on_MarkIdle()
     {
         var handle = CreateTestHandle();
         var lease = new QuicConnectionLease(handle, 10);
 
         lease.MarkBusy();
-        var afterBusy = lease.LastActivity;
+        var afterBusy = lease.LastActivityTicks;
 
         Thread.Sleep(10);
 
         lease.MarkIdle();
-        var afterIdle = lease.LastActivity;
+        var afterIdle = lease.LastActivityTicks;
 
         Assert.True(afterIdle > afterBusy);
     }

src/Servus.Akka.Tests/Transport/Quic/Client/QuicConnectionMigrationSpec.cs

@@ -63,7 +63,7 @@ public void CheckForConnectionMigration_should_detect_endpoint_change()
 
         var lease = new QuicConnectionLease(handle, 100);
 
-        sm.HandlePush(new ConnectTransport(new QuicTransportOptions { Host = "example.com", Port = 443 }));
+        sm.HandlePush([new ConnectTransport(new QuicTransportOptions { Host = "example.com", Port = 443 })]);
         sm.Dispatch(new ConnectionLeaseAcquired(lease));
 
         ops.PushedInbound.Clear();
@@ -105,7 +105,7 @@ public void CheckForConnectionMigration_should_not_detect_when_endpoint_unchange
 
         var lease = new QuicConnectionLease(handle, 100);
 
-        sm.HandlePush(new ConnectTransport(new QuicTransportOptions { Host = "example.com", Port = 443 }));
+        sm.HandlePush([new ConnectTransport(new QuicTransportOptions { Host = "example.com", Port = 443 })]);
         sm.Dispatch(new ConnectionLeaseAcquired(lease));
 
         ops.PushedInbound.Clear();

src/Servus.Akka.Tests/Transport/Quic/Client/QuicConnectionStageSpec.cs

@@ -23,7 +23,7 @@ public void Stage_should_materialize_without_error()
         var flow = Flow.FromGraph(stage);
 
         var (sourceQueue, sinkQueue) = Source
-            .Queue<ITransportOutbound>(1, OverflowStrategy.Fail)
+            .Queue<List<ITransportOutbound>>(1, OverflowStrategy.Fail)
             .ViaMaterialized(flow, Keep.Left)
             .ToMaterialized(Sink.Queue<ITransportInbound>(), Keep.Both)
             .Run(_materializer);
@@ -55,13 +55,13 @@ public async Task Stage_should_pass_ConnectTransport_to_state_machine()
         var flow = Flow.FromGraph(stage);
 
         var (sourceQueue, _) = Source
-            .Queue<ITransportOutbound>(1, OverflowStrategy.Fail)
+            .Queue<List<ITransportOutbound>>(1, OverflowStrategy.Fail)
             .ViaMaterialized(flow, Keep.Left)
             .ToMaterialized(Sink.Queue<ITransportInbound>(), Keep.Both)
             .Run(_materializer);
 
         // Push ConnectTransport
-        await sourceQueue.OfferAsync(new ConnectTransport(options));
+        await sourceQueue.OfferAsync(new List<ITransportOutbound> { new ConnectTransport(options) });
 
         // Expect Acquire message on TestActor from state machine
         var msg = ExpectMsg<QuicConnectionManagerActor.Acquire>(TimeSpan.FromSeconds(2),
@@ -89,16 +89,16 @@ public async Task Stage_should_queue_inbound_when_outlet_not_pulled()
         var flow = Flow.FromGraph(stage);
 
         var (sourceQueue, sinkQueue) = Source
-            .Queue<ITransportOutbound>(2, OverflowStrategy.Fail)
+            .Queue<List<ITransportOutbound>>(2, OverflowStrategy.Fail)
             .ViaMaterialized(flow, Keep.Left)
             .ToMaterialized(Sink.Queue<ITransportInbound>(), Keep.Both)
             .Run(_materializer);
 
-        await sourceQueue.OfferAsync(new ConnectTransport(new QuicTransportOptions
+        await sourceQueue.OfferAsync([new ConnectTransport(new QuicTransportOptions
         {
             Host = "localhost",
             Port = 443
-        }));
+        })]);
 
         var msg = ExpectMsg<QuicConnectionManagerActor.Acquire>(TimeSpan.FromSeconds(2),
             cancellationToken: TestContext.Current.CancellationToken);
@@ -116,18 +116,18 @@ public async Task Stage_should_handle_downstream_finish_signal()
         var flow = Flow.FromGraph(stage);
 
         var (sourceQueue, _) = Source
-            .Queue<ITransportOutbound>(1, OverflowStrategy.Fail)
+            .Queue<List<ITransportOutbound>>(1, OverflowStrategy.Fail)
             .ViaMaterialized(flow, Keep.Left)
             .ToMaterialized(Sink.Queue<ITransportInbound>(), Keep.Both)
             .Run(_materializer);
 
         // Test that the stage properly initializes and can handle lifecycle
         // The OnDownstreamFinish handler is called when downstream cancels
-        await sourceQueue.OfferAsync(new ConnectTransport(new QuicTransportOptions
+        await sourceQueue.OfferAsync([new ConnectTransport(new QuicTransportOptions
         {
             Host = "localhost",
             Port = 443
-        }));
+        })]);
 
         var msg = ExpectMsg<QuicConnectionManagerActor.Acquire>(TimeSpan.FromSeconds(2),
             cancellationToken: TestContext.Current.CancellationToken);
@@ -141,16 +141,16 @@ public async Task Stage_should_pull_inlet_after_inbound_push()
         var flow = Flow.FromGraph(stage);
 
         var (sourceQueue, _) = Source
-            .Queue<ITransportOutbound>(1, OverflowStrategy.Fail)
+            .Queue<List<ITransportOutbound>>(1, OverflowStrategy.Fail)
             .ViaMaterialized(flow, Keep.Left)
             .ToMaterialized(Sink.Queue<ITransportInbound>(), Keep.Both)
             .Run(_materializer);
 
-        await sourceQueue.OfferAsync(new ConnectTransport(new QuicTransportOptions
+        await sourceQueue.OfferAsync([new ConnectTransport(new QuicTransportOptions
         {
             Host = "localhost",
             Port = 443
-        }));
+        })]);
 
         var msg = ExpectMsg<QuicConnectionManagerActor.Acquire>(TimeSpan.FromSeconds(2),
             cancellationToken: TestContext.Current.CancellationToken);