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 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 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 +}