@@ -69,25 +69,25 @@ private class ListenerObserver : IObserver<DiagnosticListener>, IDisposable
69
69
}
70
70
71
71
TrySubscribe(DiagnosticSources.AuditTrailEvents.SourceName,
72
- () => new AuditDiagnosticObserver(v => WriteToConsole(v.EventName , v.Audit )));
72
+ () => new AuditDiagnosticObserver(v => WriteToConsole(v.Key , v.Value )));
73
73
74
74
TrySubscribe(DiagnosticSources.Serializer.SourceName,
75
- () => new SerializerDiagnosticObserver(v => WriteToConsole(v.EventName , v.Registration )));
75
+ () => new SerializerDiagnosticObserver(v => WriteToConsole(v.Key , v.Value )));
76
76
/**
77
77
* RequestPipeline emits a different context object for the start of the `Activity` then it does
78
78
* for the end of the `Activity` therefor `RequestPipelineDiagnosticObserver` accepts two `onNext` lambda's.
79
79
* One for the `.Start` events and one for the `.Stop` events.
80
80
*/
81
81
TrySubscribe(DiagnosticSources.RequestPipeline.SourceName,
82
82
() => 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 )
85
85
));
86
86
87
87
TrySubscribe(DiagnosticSources.HttpConnection.SourceName,
88
88
() => 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 )
91
91
));
92
92
}
93
93
0 commit comments