From d626bdb1bae03a926c169c0194104a9832853d1e Mon Sep 17 00:00:00 2001
From: ahmed <ahmed@esiur.com>
Date: Thu, 4 Jun 2026 18:31:19 +0300
Subject: [PATCH] Keep fanout sweep subscriptions alive

---
 Tests/Distribution/NodeFanoutSweep/Client/Program.cs | 4 +++-
 1 file changed, 3 insertions(+), 1 deletion(-)

diff --git a/Tests/Distribution/NodeFanoutSweep/Client/Program.cs b/Tests/Distribution/NodeFanoutSweep/Client/Program.cs
index b03d372..3559cd9 100644
--- a/Tests/Distribution/NodeFanoutSweep/Client/Program.cs
+++ b/Tests/Distribution/NodeFanoutSweep/Client/Program.cs
@@ -303,6 +303,7 @@ static async Task<SubscriberTask?> SpawnSubscriber(
         for (int i = 0; i < resources; i++)
         {
             var proxy = await conn.Get($"sys/sensor_{i}");
+            sub.Resources.Add(proxy);
             long lastTick = Stopwatch.GetTimestamp();
 
             proxy.Instance.PropertyModified += (PropertyModificationInfo data) =>
@@ -385,6 +386,7 @@ static string GetArg(string[] args, string key, string def)
 class SubscriberTask
 {
     public int SubscriberId;
+    public readonly List<IResource> Resources = new();
     internal long _received;
     internal long _lateDeliveries;
     public long Received => Interlocked.Read(ref _received);
@@ -424,4 +426,4 @@ record SweepResult
     public double MeanServerCpuPeak;
     public double MeanClientCpuAvg;
     public double MeanClientCpuPeak;
-}
\ No newline at end of file
+}