30 lines
758 B
Rust
30 lines
758 B
Rust
#![deny(warnings)]
|
|
|
|
use futures::{Future, Stream};
|
|
use reqwest::r#async::{Client, Decoder};
|
|
use std::io::{self, Cursor};
|
|
use std::mem;
|
|
|
|
fn fetch() -> impl Future<Item = (), Error = ()> {
|
|
Client::new()
|
|
.get("https://hyper.rs")
|
|
.send()
|
|
.and_then(|mut res| {
|
|
println!("{}", res.status());
|
|
|
|
let body = mem::replace(res.body_mut(), Decoder::empty());
|
|
body.concat2()
|
|
})
|
|
.map_err(|err| println!("request error: {}", err))
|
|
.map(|body| {
|
|
let mut body = Cursor::new(body);
|
|
let _ = io::copy(&mut body, &mut io::stdout()).map_err(|err| {
|
|
println!("stdout error: {}", err);
|
|
});
|
|
})
|
|
}
|
|
|
|
fn main() {
|
|
tokio::run(fetch());
|
|
}
|