@@ -173,51 +173,56 @@ await Task.WhenAny(
173173
174174 if ( ! string . IsNullOrEmpty ( response ) )
175175 {
176- dynamic obj = JsonConvert . DeserializeObject ( response ) ;
177- var objAsJObject = obj as JObject ;
176+ ProcessResponse ( response ) ;
177+ }
178+ }
179+ }
178180
179- if ( objAsJObject [ "id" ] != null )
180- {
181- int id = ( int ) objAsJObject [ "id" ] ;
181+ private void ProcessResponse ( string response )
182+ {
183+ dynamic obj = JsonConvert . DeserializeObject ( response ) ;
184+ var objAsJObject = obj as JObject ;
182185
183- //If we get the object we are waiting for we return if
184- //if not we add this to the list, sooner or later some one will come for it
185- if ( ! _responses . ContainsKey ( id ) )
186- {
187- QueueId ( id ) ;
188- }
186+ if ( objAsJObject [ "id" ] != null )
187+ {
188+ int id = ( int ) objAsJObject [ "id" ] ;
189+
190+ //If we get the object we are waiting for we return if
191+ //if not we add this to the list, sooner or later some one will come for it
192+ if ( ! _responses . ContainsKey ( id ) )
193+ {
194+ QueueId ( id ) ;
195+ }
189196
190- _responses [ id ] . SetResult ( obj . result ) ;
197+ _responses [ id ] . SetResult ( obj . result ) ;
198+ }
199+ else
200+ {
201+ if ( obj . method == "Target.receivedMessageFromTarget" )
202+ {
203+ var session = _sessions . GetValueOrDefault ( objAsJObject [ "params" ] [ "sessionId" ] . ToString ( ) ) ;
204+ if ( session != null )
205+ {
206+ session . OnMessage ( objAsJObject [ "params" ] [ "message" ] . ToString ( ) ) ;
191207 }
192- else
208+ }
209+ else if ( obj . method == "Target.detachedFromTarget" )
210+ {
211+ var session = _sessions . GetValueOrDefault ( objAsJObject [ "params" ] [ "sessionId" ] . ToString ( ) ) ;
212+ if ( session != null )
193213 {
194- if ( obj . method == "Target.receivedMessageFromTarget" )
195- {
196- var session = _sessions . GetValueOrDefault ( objAsJObject [ "params" ] [ "sessionId" ] . ToString ( ) ) ;
197- if ( session != null )
198- {
199- session . OnMessage ( objAsJObject [ "params" ] [ "message" ] . ToString ( ) ) ;
200- }
201- }
202- else if ( obj . method == "Target.detachedFromTarget" )
203- {
204- var session = _sessions . GetValueOrDefault ( objAsJObject [ "params" ] [ "sessionId" ] . ToString ( ) ) ;
205- if ( session != null )
206- {
207- session . Close ( ) ;
208- }
209-
210- _sessions . Remove ( objAsJObject [ "params" ] [ "sessionId" ] . ToString ( ) ) ;
211- }
212- else
213- {
214- MessageReceived ? . Invoke ( this , new MessageEventArgs
215- {
216- MessageID = obj . method ,
217- MessageData = objAsJObject [ "params" ] as dynamic
218- } ) ;
219- }
214+ session . Close ( ) ;
220215 }
216+
217+ _sessions . Remove ( objAsJObject [ "params" ] [ "sessionId" ] . ToString ( ) ) ;
218+ }
219+ else
220+ {
221+ MessageReceived ? . Invoke ( this , new MessageEventArgs
222+ {
223+ MessageID = obj . method ,
224+ MessageData = objAsJObject [ "params" ] as dynamic
225+ } ) ;
221226 }
222227 }
223228 }
0 commit comments