Made unit test more robust (#307)

microsoft · Mar 21, 2024 · 6703aa7 · 6703aa7
1 parent fca7fa9
commit 6703aa7
Showing 1 changed file with 27 additions and 28 deletions.
diff --git a/Sources/Runtime/Test.Psi/PipelineTest.cs b/Sources/Runtime/Test.Psi/PipelineTest.cs
@@ -1976,36 +1976,35 @@ public void DiagnosticsTest()
             var log = new List<string>();
             PipelineDiagnostics graph = null;
 
-            using (var p = Pipeline.Create(enableDiagnostics: true, diagnosticsConfiguration: new DiagnosticsConfiguration() { SamplingInterval = TimeSpan.FromMilliseconds(1) }))
-            {
-                /*
-                 *         .........
-                 *  =---=  . =---= .  =---=
-                 *  | A |--->| B |--->| D |---+
-                 *  =---=  . =---= .  =---=   |
-                 *    ^    .........          |
-                 *    |                       |
-                 *    +-----------------------+
-                 */
-                var sub = new Subpipeline(p);
-                var cIn = new Connector<int>(p, sub);
-                var cOut = new Connector<int>(sub, p);
-                var d = new FinalizationTestComponent(p, "C", log);
-                var b = new FinalizationTestComponent(sub, "B", log);
-                var a = new FinalizationTestComponent(p, "A", log);
-                var timer = Generators.Range(p, 0, 100, TimeSpan.FromMilliseconds(10));
-                timer.PipeTo(cIn.In);
-                cIn.Out.PipeTo(b.ReceiverX);
-                b.RelayFromX.PipeTo(cOut.In);
-                cOut.Out.PipeTo(d.ReceiverX);
+            using var p = Pipeline.Create(enableDiagnostics: true, diagnosticsConfiguration: new DiagnosticsConfiguration() { SamplingInterval = TimeSpan.FromMilliseconds(10) });
+
+            /*
+             *         .........
+             *  =---=  . =---= .  =---=
+             *  | A |--->| B |--->| D |---+
+             *  =---=  . =---= .  =---=   |
+             *    ^    .........          |
+             *    |                       |
+             *    +-----------------------+
+             */
+            var sub = new Subpipeline(p);
+            var cIn = new Connector<int>(p, sub);
+            var cOut = new Connector<int>(sub, p);
+            var d = new FinalizationTestComponent(p, "C", log);
+            var b = new FinalizationTestComponent(sub, "B", log);
+            var a = new FinalizationTestComponent(p, "A", log);
+            var timer = Generators.Range(p, 0, 100, TimeSpan.FromMilliseconds(10));
+            timer.PipeTo(cIn.In);
+            cIn.Out.PipeTo(b.ReceiverX);
+            b.RelayFromX.PipeTo(cOut.In);
+            cOut.Out.PipeTo(d.ReceiverX);
 
-                p.Diagnostics.Do(diag => graph = diag.DeepClone());
+            p.Diagnostics.Do(diag => graph = diag.DeepClone());
 
-                p.RunAsync();
-                while (graph == null)
-                {
-                    Thread.Sleep(10);
-                }
+            p.RunAsync();
+            while (graph == null)
+            {
+                Thread.Sleep(10);
             }
 
             Assert.AreEqual(2, graph.GetPipelineCount()); // total graphs