boomnet 0.0.78

Framework for building low latency clients on top of TCP.
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36

use boomnet::http::{ConnectionPool, SingleTlsConnectionPool};
use http::Method;

fn main() -> anyhow::Result<()> {
    let mut client = SingleTlsConnectionPool::new(("fapi.binance.com", 443)).into_http_client();

    let request =
        client.new_request_with_headers(Method::GET, "/fapi/v1/depth?symbol=BTCUSDT", None, move |headers| {
            headers["FOO"] = "bar";
        })?;

    // execute in blocking mode (will consume request)
    let (status_code, headers, body) = request.block()?;
    println!("{status_code}");
    println!("{headers}");
    println!("{body}");

    // execute in async mode (we must provide own buffer)
    let mut request = client.new_request(Method::GET, "/fapi/v1/time", None)?;
    loop {
        if let Some((status_code, headers, body)) = request.poll()? {
            println!("{status_code}");
            println!("{headers}");
            println!("{body}");
            break;
        }
    }

    // once the request is done, polling it again will just return the same data
    let (status_code, headers, body) = request.poll()?.unwrap();
    println!("{status_code}");
    println!("{headers}");
    println!("{body}");

    Ok(())
}