@@ -15,20 +15,18 @@ internal class Broker
1515 {
1616 private readonly ILogger logger ;
1717 private readonly Process process ;
18- private readonly IDiagnoser diagnoser ;
1918 private readonly AnonymousPipeServerStream inputFromBenchmark , acknowledgments ;
20- private readonly DiagnoserActionParameters diagnoserActionParameters ;
2119 private readonly ManualResetEvent finished ;
2220
2321 public Broker ( ILogger logger , Process process , IDiagnoser diagnoser ,
2422 BenchmarkCase benchmarkCase , BenchmarkId benchmarkId , AnonymousPipeServerStream inputFromBenchmark , AnonymousPipeServerStream acknowledgments )
2523 {
2624 this . logger = logger ;
2725 this . process = process ;
28- this . diagnoser = diagnoser ;
26+ this . Diagnoser = diagnoser ;
2927 this . inputFromBenchmark = inputFromBenchmark ;
3028 this . acknowledgments = acknowledgments ;
31- diagnoserActionParameters = new DiagnoserActionParameters ( process , benchmarkCase , benchmarkId ) ;
29+ DiagnoserActionParameters = new DiagnoserActionParameters ( process , benchmarkCase , benchmarkId ) ;
3230 finished = new ManualResetEvent ( false ) ;
3331
3432 Results = new List < string > ( ) ;
@@ -38,6 +36,10 @@ public Broker(ILogger logger, Process process, IDiagnoser diagnoser,
3836 process . Exited += OnProcessExited ;
3937 }
4038
39+ internal IDiagnoser Diagnoser { get ; }
40+
41+ internal DiagnoserActionParameters DiagnoserActionParameters { get ; }
42+
4143 internal List < string > Results { get ; }
4244
4345 internal List < string > PrefixedOutput { get ; }
@@ -90,7 +92,7 @@ private void ProcessDataBlocking()
9092 }
9193 else if ( Engine . Signals . TryGetSignal ( line , out var signal ) )
9294 {
93- diagnoser ? . Handle ( signal , diagnoserActionParameters ) ;
95+ Diagnoser ? . Handle ( signal , DiagnoserActionParameters ) ;
9496
9597 writer . WriteLine ( Engine . Signals . Acknowledgment ) ;
9698
0 commit comments