hyper_async_await.rs

#![feature(await_macro, async_await, futures_api)]

#[macro_use]
extern crate tokio;
extern crate hyper;

use tokio::prelude::*;
use hyper::Client;

use std::time::Duration;
use std::str;

async fn do_request() -> Result<String, hyper::error::Error> {
    let client = Client::new();

    let uri = "http://httpbin.org/ip".parse().unwrap();

    let response = await!(
        client
            .get(uri)
            .timeout(Duration::from_secs(10))
    ).unwrap();

    let body = await!(response.into_body().concat2()).unwrap();
    Ok(String::from_utf8(body.to_vec()).unwrap())
}

pub fn main() {
    tokio::run_async(async {
        match await!(do_request()) {
            Ok(body) => println!("{}", body),
            Err(e) => println!("ERROR: {:?}", e)
        }
    });
}