tower-hyper 0.1.1

A hyper based tower transport layer.
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
37
38
39
40
41
42
43

use futures::{future, Future};
use http::{Method, Request, Uri};
use hyper::rt;
use std::time::Duration;
use tokio_buf::util::BufStreamExt;
use tower::{Service, ServiceBuilder, ServiceExt};
use tower_http_util::body::BodyExt;
use tower_hyper::client::Client;

fn main() {
    rt::run(future::lazy(|| {
        let uri = "http://httpbin.org/ip".parse::<Uri>().unwrap();
        let hyper = Client::new();

        let request = Request::builder()
            .uri(uri)
            .method(Method::GET)
            .body(Vec::new())
            .unwrap();

        let svc = ServiceBuilder::new()
            .buffer(5)
            .timeout(Duration::from_secs(5))
            .service(hyper);

        svc.ready()
            .and_then(|mut svc| svc.call(request))
            .map_err(|err| eprintln!("Request Error: {}", err))
            .and_then(|response| {
                println!("Response Status: {:?}", response.status());
                response
                    .into_body()
                    .into_buf_stream()
                    .collect::<Vec<u8>>()
                    .map(|v| String::from_utf8(v).unwrap())
                    .map_err(|e| eprintln!("Body Error: {:?}", e))
            })
            .and_then(|body| {
                println!("Response Body: {}", body);
                Ok(())
            })
    }));
}