(response: &Value)
| 798 | } |
| 799 | |
| 800 | fn inspector_info_from_response(response: &Value) -> Option<Value> { |
| 801 | let result = response.get("result")?; |
| 802 | if result |
| 803 | .get("protocolVersion") |
| 804 | .and_then(Value::as_str) |
| 805 | .is_some() |
| 806 | && result |
| 807 | .get("processIdentifier") |
| 808 | .and_then(Value::as_i64) |
| 809 | .is_some() |
| 810 | { |
| 811 | Some(result.clone()) |
| 812 | } else { |
| 813 | None |
| 814 | } |
| 815 | } |
| 816 | |
| 817 | async fn fail_all_pending(pending: &PendingResponses, message: &str) { |
| 818 | let mut pending = pending.lock().await; |
no test coverage detected