@@ -110,6 +110,9 @@ public async Task EventListener(string id, CancellationToken cancellationToken,
110
110
case Events . ResponseCreated :
111
111
await OnResponseCreated ( id , cancellationToken , getEventData , signal , processRecordId ) ;
112
112
break ;
113
+ case Events . Polling :
114
+ await OnPolling ( id , cancellationToken , getEventData , signal , processRecordId ) ;
115
+ break ;
113
116
default :
114
117
getEventData . Print ( signal , cancellationToken , Events . Information , id ) ;
115
118
break ;
@@ -142,6 +145,33 @@ await signal(Events.Debug, cancellationToken,
142
145
}
143
146
}
144
147
148
+ internal async Task OnPolling ( string id , CancellationToken cancellationToken , GetEventData getEventData , SignalDelegate signal , string processRecordId )
149
+ {
150
+ var data = EventDataConverter . ConvertFrom ( getEventData ( ) ) ;
151
+ // a polling event contains a response, and the response contains the request
152
+ // so we can print them both in one event
153
+ if ( data ? . RequestMessage is HttpRequestMessage request )
154
+ {
155
+ try {
156
+ // Print formatted request message
157
+ await signal ( Events . Debug , cancellationToken ,
158
+ ( ) => EventHelper . CreateLogEvent ( GeneralUtilities . GetLog ( request ) ) ) ;
159
+ } catch {
160
+ // request was disposed, ignore
161
+ }
162
+ }
163
+ if ( data ? . ResponseMessage is HttpResponseMessage response )
164
+ {
165
+ try {
166
+ // Print formatted response message
167
+ await signal ( Events . Debug , cancellationToken ,
168
+ ( ) => EventHelper . CreateLogEvent ( GeneralUtilities . GetLog ( response ) ) ) ;
169
+ } catch {
170
+ // response was disposed, ignore
171
+ }
172
+ }
173
+ }
174
+
145
175
internal async Task OnCmdletException ( string id , CancellationToken cancellationToken , GetEventData getEventData , SignalDelegate signal , string processRecordId , Exception exception )
146
176
{
147
177
var data = EventDataConverter . ConvertFrom ( getEventData ( ) ) ;
0 commit comments