openwire 0.1.0

OkHttp-inspired async HTTP client for Rust built on hyper and tower
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

use std::net::{IpAddr, Ipv4Addr, SocketAddr};

use http::Request;
use openwire::{BoxFuture, CallContext, Client, DnsResolver, RequestBody, WireError};

#[derive(Clone)]
struct LoopbackResolver;

impl DnsResolver for LoopbackResolver {
    fn resolve(
        &self,
        ctx: CallContext,
        host: String,
        port: u16,
    ) -> BoxFuture<Result<Vec<SocketAddr>, WireError>> {
        Box::pin(async move {
            let addr = SocketAddr::new(IpAddr::V4(Ipv4Addr::LOCALHOST), port);
            ctx.listener().dns_start(&ctx, &host, port);
            ctx.listener().dns_end(&ctx, &host, &[addr]);
            Ok(vec![addr])
        })
    }
}

#[tokio::main]
async fn main() -> Result<(), Box<dyn std::error::Error>> {
    let client = Client::builder().dns_resolver(LoopbackResolver).build()?;
    let request = Request::builder()
        .uri("http://openwire.local:8080/")
        .body(RequestBody::empty())?;
    let response = client.execute(request).await?;
    println!("status = {}", response.status());
    Ok(())
}