Function send_request

perro_source/api_modules/perro_networking/src/http.rs:517–601

(
    agent: &ureq::Agent,
    config: &HttpConfig,
    id: HttpID,
    request: HttpRequest,
)

            HttpMethod::Patch,
            url,
            HttpBody::Variant(body),
        ))
    }

    pub fn post_bytes(&mut self, url: impl Into<String>, body: Vec<u8>) -> HttpID {
        self.request(HttpRequest::post_bytes(url, body))
    }

    pub fn poll(&mut self) -> Option<HttpEvent> {
        if let Some(event) = self.local_events.pop_front() {
            return Some(event);
        }
        self.rx.try_recv().ok()
    }

    pub fn poll_all(&mut self, max_events: usize) -> Vec<HttpEvent> {
        let mut out = Vec::new();
        for _ in 0..max_events {
            let Some(event) = self.poll() else {
                break;
            };
            out.push(event);
        }
        out
    }

    pub fn config(&self) -> &HttpConfig {
        &self.config
    }

    pub fn queue_config(&self) -> HttpQueueConfig {
        self.queue_config
    }

    pub fn rejected_requests(&self) -> u64 {
        self.rejected_requests
    }

    fn next_http_id(&mut self) -> HttpID {
        let id = HttpID(self.next_id);
        self.next_id = self.next_id.wrapping_add(1);
        id
    }
}

impl Default for HttpClient {
    fn default() -> Self {
        Self::new()
    }
}

fn http_worker(
    config: HttpConfig,
    work_rx: Arc<Mutex<Receiver<HttpWork>>>,
    event_tx: SyncSender<HttpEvent>,
    shared_agent: Option<ureq::Agent>,
) {
    loop {