Module ehttp::streaming

let your_chunk_handler = std::sync::Arc::new(|chunk: Vec<u8>| {
    if chunk.is_empty() {
        return std::ops::ControlFlow::Break(());
    }

    println!("received chunk: {} bytes", chunk.len());
    std::ops::ControlFlow::Continue(())
});

let url = "https://www.example.com";
let request = ehttp::Request::get(url);
ehttp::streaming::fetch(request, move |result: ehttp::Result<ehttp::streaming::Part>| {
    let part = match result {
        Ok(part) => part,
        Err(err) => {
            eprintln!("an error occurred while streaming `{url}`: {err}");
            return std::ops::ControlFlow::Break(());
        }
    };

    match part {
        ehttp::streaming::Part::Response(response) => {
            println!("Status code: {:?}", response.status);
            if response.ok {
                std::ops::ControlFlow::Continue(())
            } else {
                std::ops::ControlFlow::Break(())
            }
        }
        ehttp::streaming::Part::Chunk(chunk) => {
            your_chunk_handler(chunk)
        }
    }
});