Function complete_pending_response_value

packages/server/src/inspector.rs:777–798

(pending: &PendingResponses, value: Value)

}

async fn complete_pending_response_value(pending: &PendingResponses, value: Value) {
    let Some(id) = value.get("id").and_then(Value::as_u64) else {
        return;
    };
    let Some(response_tx) = pending.lock().await.remove(&id) else {
        return;
    };

    let result = if let Some(error) = value.get("error") {
        Err(error
            .get("message")
            .and_then(Value::as_str)
            .map(str::to_owned)
            .unwrap_or_else(|| error.to_string()))
    } else {
        value
            .get("result")
            .cloned()
            .ok_or_else(|| "Inspector response did not include result.".to_owned())
    };
    let _ = response_tx.send(result);
}

fn inspector_info_from_response(response: &Value) -> Option<Value> {
    let result = response.get("result")?;