Revert test proxy threads to tasks

nats-io · Oct 10, 2023 · a652ea0 · a652ea0
1 parent fe70da1
commit a652ea0
Showing 1 changed file with 6 additions and 6 deletions.
diff --git a/tests/NATS.Client.TestUtilities/NatsProxy.cs b/tests/NATS.Client.TestUtilities/NatsProxy.cs
@@ -24,7 +24,7 @@ public NatsProxy(int port, ITestOutputHelper outputHelper, bool trace)
         _tcpListener.Start();
         _watch.Restart();
 
-        new Thread(() =>
+        Task.Run(() =>
         {
             var client = 0;
             while (true)
@@ -48,7 +48,7 @@ public NatsProxy(int port, ITestOutputHelper outputHelper, bool trace)
                 var n = client++;
 
 #pragma warning disable CS4014
-                new Thread(() =>
+                Task.Run(() =>
                 {
                     var stream1 = tcpClient1.GetStream();
                     var sr1 = new StreamReader(stream1, Encoding.ASCII);
@@ -58,19 +58,19 @@ public NatsProxy(int port, ITestOutputHelper outputHelper, bool trace)
                     var sr2 = new StreamReader(stream2, Encoding.ASCII);
                     var sw2 = new StreamWriter(stream2, Encoding.ASCII);
 
-                    new Thread(() =>
+                    Task.Run(() =>
                     {
                         while (NatsProtoDump(n, "C", sr1, sw2, ClientInterceptor))
                         {
                         }
-                    }) { IsBackground = true, Name = $"nats-proxy-writer-{n}" }.Start();
+                    });
 
                     while (NatsProtoDump(n, $"S", sr2, sw1, ServerInterceptor))
                     {
                     }
-                }) { IsBackground = true, Name = $"nats-proxy-reader-{n}" }.Start();
+                });
             }
-        }) { IsBackground = true, Name = "nats-proxy-srv" }.Start();
+        });
 
         var stopwatch = Stopwatch.StartNew();
         while (stopwatch.Elapsed < TimeSpan.FromSeconds(10))