32 releases

new 0.4.7 Apr 8, 2025
0.4.6 Feb 21, 2025
0.4.3 Apr 5, 2024
0.4.1 Mar 6, 2024
0.1.3 Mar 26, 2023

#118 in HTTP client

Download history 2/week @ 2024-12-20 12/week @ 2024-12-27 14/week @ 2025-01-03 9/week @ 2025-01-10 2/week @ 2025-01-17 17/week @ 2025-01-24 78/week @ 2025-01-31 349/week @ 2025-02-07 289/week @ 2025-02-14 435/week @ 2025-02-21 286/week @ 2025-02-28 152/week @ 2025-03-07 88/week @ 2025-03-14 55/week @ 2025-03-21 43/week @ 2025-03-28 193/week @ 2025-04-04

384 downloads per month
Used in 2 crates

MIT license

120KB
1.5K SLoC

async-curl

This will perform curl Easy2 asynchronously for rust-lang via an Actor using tokio

Latest Version License Documentation Build Status Downloads

How to use with multiple async request

use async_curl::{Actor, CurlActor};
use curl::easy::{Easy2, Handler, WriteError};

#[derive(Debug, Clone, Default)]
pub struct ResponseHandler {
    data: Vec<u8>,
}

impl Handler for ResponseHandler {
    /// This will store the response from the server
    /// to the data vector.
    fn write(&mut self, data: &[u8]) -> Result<usize, WriteError> {
        self.data.extend_from_slice(data);
        Ok(data.len())
    }
}

impl ResponseHandler {
    /// Instantiation of the ResponseHandler
    /// and initialize the data vector.
    pub fn new() -> Self {
        Self::default()
    }

    /// This will consumed the object and
    /// give the data to the caller
    pub fn get_data(self) -> Vec<u8> {
        self.data
    }
}

#[tokio::main(flavor = "current_thread")]
async fn main() {
    let actor = CurlActor::new();

    let mut easy2 = Easy2::new(ResponseHandler::new());
    easy2.url("https://www.rust-lang.org/").unwrap();
    easy2.get(true).unwrap();

    let actor1 = actor.clone();
    let spawn1 = tokio::spawn(async move {
        let mut result = actor1.send_request(easy2).await.unwrap();

        let response = result.get_ref().to_owned().get_data();
        let status = result.response_code().unwrap();

        println!("Response: {:?}", response);
        println!("Status: {:?}", status);
    });

    let mut easy2 = Easy2::new(ResponseHandler::new());
    easy2.url("https://www.rust-lang.org/").unwrap();
    easy2.get(true).unwrap();

    let spawn2 = tokio::spawn(async move {
        let mut result = actor.send_request(easy2).await.unwrap();

        let response = result.get_ref().to_owned().get_data();
        let status = result.response_code().unwrap();

        println!("Response: {:?}", response);
        println!("Status: {:?}", status);
    });

    let (_, _) = tokio::join!(spawn1, spawn2);
}

Dependencies

~12–20MB
~299K SLoC