@@ -69,25 +69,25 @@ private class ListenerObserver : IObserver<DiagnosticListener>, IDisposable
6969 }
7070
7171 TrySubscribe(DiagnosticSources.AuditTrailEvents.SourceName,
72- () => new AuditDiagnosticObserver(v => WriteToConsole(v.EventName , v.Audit )));
72+ () => new AuditDiagnosticObserver(v => WriteToConsole(v.Key , v.Value )));
7373
7474 TrySubscribe(DiagnosticSources.Serializer.SourceName,
75- () => new SerializerDiagnosticObserver(v => WriteToConsole(v.EventName , v.Registration )));
75+ () => new SerializerDiagnosticObserver(v => WriteToConsole(v.Key , v.Value )));
7676 /**
7777 * RequestPipeline emits a different context object for the start of the `Activity` then it does
7878 * for the end of the `Activity` therefor `RequestPipelineDiagnosticObserver` accepts two `onNext` lambda's.
7979 * One for the `.Start` events and one for the `.Stop` events.
8080 */
8181 TrySubscribe(DiagnosticSources.RequestPipeline.SourceName,
8282 () => new RequestPipelineDiagnosticObserver(
83- v => WriteToConsole(v.EventName , v.RequestData ),
84- v => WriteToConsole(v.EventName , v.Response )
83+ v => WriteToConsole(v.Key , v.Value ),
84+ v => WriteToConsole(v.Key , v.Value )
8585 ));
8686
8787 TrySubscribe(DiagnosticSources.HttpConnection.SourceName,
8888 () => new HttpConnectionDiagnosticObserver(
89- v => WriteToConsole(v.EventName , v.RequestData ),
90- v => WriteToConsole(v.EventName , v.StatusCode )
89+ v => WriteToConsole(v.Key , v.Value ),
90+ v => WriteToConsole(v.Key , v.Value )
9191 ));
9292 }
9393
0 commit comments